From e5aa97f90f1d7b6a51a12a2e533c3e280c255b97 Mon Sep 17 00:00:00 2001
From: bernd2022 <bernd.nospam.2018@t-online.de>
Date: Fri, 15 Aug 2025 16:12:55 +0200
Subject: [PATCH] [NO-TASK] MinAmount for Saving and Bridge posts

---
 bridge/bridge.service.ts             |  3 ++-
 frontendcode/frontendcode.service.ts | 13 ++++++++-----
 socialmedia/socialmedia.service.ts   |  9 +++++++--
 3 files changed, 17 insertions(+), 8 deletions(-)

diff --git a/bridge/bridge.service.ts b/bridge/bridge.service.ts
index 062317c..caf1ed8 100644
--- a/bridge/bridge.service.ts
+++ b/bridge/bridge.service.ts
@@ -7,7 +7,7 @@ import { StablecoinEnum } from './bridge.enum';
 
 @Injectable()
 export class BridgeService {
-	async getBridgedStables(stablecoin: StablecoinEnum, timestamp: Date): Promise<StablecoinBridgeQuery[]> {
+	async getBridgedStables(stablecoin: StablecoinEnum, timestamp: Date, minAmount: bigint): Promise<StablecoinBridgeQuery[]> {
 		const checkTimestamp = Math.trunc(timestamp.getTime() / 1000);
 
 		const bridgeFetched = await PONDER_CLIENT.query({
@@ -18,6 +18,7 @@ export class BridgeService {
                         orderBy: "timestamp", orderDirection: "desc"
                         where: {
                             timestamp_gt: "${checkTimestamp}"
+                            amount_gte: "${minAmount}"
                             isMint: true
                         }
                     ) {
diff --git a/frontendcode/frontendcode.service.ts b/frontendcode/frontendcode.service.ts
index 2ab9fcf..4a4bd4d 100644
--- a/frontendcode/frontendcode.service.ts
+++ b/frontendcode/frontendcode.service.ts
@@ -29,16 +29,19 @@ export class FrontendCodeService {
 		return frontendCodeFetched?.data?.frontendCodeRegistereds?.items ?? [];
 	}
 
-	async getSavingsSaveds(timestamp: Date): Promise<FrontendCodeSavingsQuery[]> {
+	async getSavingsSaveds(timestamp: Date, minAmount: bigint): Promise<FrontendCodeSavingsQuery[]> {
 		const checkTimestamp = Math.trunc(timestamp.getTime() / 1000);
 
 		const savedFetched = await PONDER_CLIENT.query({
 			fetchPolicy: 'no-cache',
 			query: gql`
-				query GetFrontendCodeSavingsSaved {
-					savingsSaveds(
-						orderBy: "created", orderDirection: "desc"
-						where: { created_gt: "${checkTimestamp}" }
+			query GetFrontendCodeSavingsSaved {
+				savingsSaveds(
+					orderBy: "created", orderDirection: "desc"
+					where: { 
+							created_gt: "${checkTimestamp}"
+							amount_gte: "${minAmount}"
+						}
 					) {
 						items {
 							txHash
diff --git a/socialmedia/socialmedia.service.ts b/socialmedia/socialmedia.service.ts
index 34a0fb6..c451eb2 100644
--- a/socialmedia/socialmedia.service.ts
+++ b/socialmedia/socialmedia.service.ts
@@ -17,6 +17,9 @@ export interface SocialMediaFct {
 	doSendBridgeUpdates(bridge: StablecoinBridgeQuery, stablecoin: string): Promise<void>;
 }
 
+const MIN_SAVING_AMOUNT = 1000;
+const MIN_BRIDGE_AMOUNT = 5000;
+
 @Injectable()
 export class SocialMediaService {
 	private readonly logger = new Logger(this.constructor.name);
@@ -71,7 +74,8 @@ export class SocialMediaService {
 	private async sendSavingUpdates(): Promise<void> {
 		try {
 			const checkDate = new Date(this.socialMediaState.savingUpdates);
-			const requestedSavingsSaveds = await this.frontendCode.getSavingsSaveds(checkDate);
+			const minAmount = BigInt(MIN_SAVING_AMOUNT * 10 ** 18);
+			const requestedSavingsSaveds = await this.frontendCode.getSavingsSaveds(checkDate, minAmount);
 
 			if (requestedSavingsSaveds.length > 0) {
 				this.socialMediaState.savingUpdates = Date.now();
@@ -133,9 +137,10 @@ export class SocialMediaService {
 	private async sendBridgeUpdates(): Promise<void> {
 		try {
 			const checkDate = new Date(this.socialMediaState.bridgeUpdates);
+			const minAmount = BigInt(MIN_BRIDGE_AMOUNT * 10 ** 18);
 
 			for (const stablecoin of Object.values(StablecoinEnum)) {
-				const requestedBridged = await this.bridges.getBridgedStables(stablecoin, checkDate);
+				const requestedBridged = await this.bridges.getBridgedStables(stablecoin, checkDate, minAmount);
 
 				if (requestedBridged.length > 0) {
 					this.socialMediaState.bridgeUpdates = Date.now();