Skip to content

unsubscribe user added #9

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
megabyte0x merged 1 commit into from
May 11, 2025
Merged

unsubscribe user added #9

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
20 changes: 20 additions & 0 deletions backend/MCP_Execution_Server/src/routes/user.routes.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -67,5 +67,25 @@ export function userRouter(userService: UserService): Router {
}
},
);

router.post(
"/unsubscribe/user",
async (req: Request, res: Response, next: NextFunction): Promise<void> => {
const { fid } = req.body;

if (!fid) {
res.status(400).json({ error: "Missing User FID" });
return;
}

try {
const result = await userService.unsubscribeUser(fid);
res.status(200).json({ success: true, data: result });
} catch (error) {
console.error("Error in /unsubscribe/user:", error);
next(error);
}
},
);
return router;
}
329 changes: 189 additions & 140 deletions backend/MCP_Execution_Server/src/services/db.service.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,172 +1,221 @@

import { createClient } from "@supabase/supabase-js";
import type { SupabaseClient } from "@supabase/supabase-js";

export class DBService {
supabase: SupabaseClient;
constructor(SUPABASE_URL: string, SUPABASE_ANON_KEY: string) {
this.supabase = createClient(
SUPABASE_URL,
SUPABASE_ANON_KEY
);
supabase: SupabaseClient;
constructor(SUPABASE_URL: string, SUPABASE_ANON_KEY: string) {
this.supabase = createClient(SUPABASE_URL, SUPABASE_ANON_KEY);
}

async fetchSubscriberCount() {
try {
const { data, error } = await this.supabase
.from("user_embeddings")
.select("fid")
.eq("is_subscribed", true);
if (error) throw error;
return { success: true, data: data.length };
} catch (err: any) {
console.error("fetchSubscriberCount error", err);
return { success: false, error: err.message || err, data: 0 };
}
}

async fetchSubscriberCount() {
try {
const { data, error } = await this.supabase.from("user_embeddings").select("fid").eq("is_subscribed", true);
if (error) throw error;
return { success: true, data: data.length };
} catch (err: any) {
console.error("fetchSubscriberCount error", err);
return { success: false, error: err.message || err, data: 0 };
}
async getUser(fid: number) {
try {
const { data, error } = await this.supabase
.from("user_embeddings")
.select("*")
.eq("fid", fid);
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("getUser error", err);
return { success: false, error: err.message || err };
}
}

async getUser(fid: number) {
try {
const { data, error } = await this.supabase.from("user_embeddings").select("*").eq("fid", fid);
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("getUser error", err);
return { success: false, error: err.message || err };
}
async isSubscribed(fid: number) {
try {
const { data, error } = await this.supabase
.from("user_embeddings")
.select("fid")
.eq("fid", fid)
.eq("is_subscribed", true)
.maybeSingle();
if (error) throw error;
return { success: true, subscribed: !!data };
} catch (err: any) {
console.error("checkSubscribedUser error", err);
return { success: false, error: err.message || err };
}
}

async isSubscribed(fid: number) {
try {
const { data, error } = await this.supabase
.from("user_embeddings")
.select("fid")
.eq("fid", fid)
.eq("is_subscribed", true)
.maybeSingle();
if (error) throw error;
return { success: true, subscribed: !!data };
} catch (err: any) {
console.error("checkSubscribedUser error", err);
return { success: false, error: err.message || err };
}
async unsubscribeFID(fid: number) {
try {
const { data, error } = await this.supabase
.from("user_embeddings")
.update({ is_subscribed: false })
.eq("fid", fid);
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("unsubscribeFID error", err);
return { success: false, error: err.message || err };
}
}

async isRegistered(fid: number) {
try {
const { data, error } = await this.supabase.from("user_embeddings").select("fid").eq("fid", fid).maybeSingle();
if (error) throw error;
return { success: true, registered: !!data };
} catch (err: any) {
console.error("isRegistered error", err);
return { success: false, error: err.message || err };
}
async isRegistered(fid: number) {
try {
const { data, error } = await this.supabase
.from("user_embeddings")
.select("fid")
.eq("fid", fid)
.maybeSingle();
if (error) throw error;
return { success: true, registered: !!data };
} catch (err: any) {
console.error("isRegistered error", err);
return { success: false, error: err.message || err };
}
}

async registerAndSubscribeFID(fid: string, summary: any, embeddings: any) {
try {
const { data, error } = await this.supabase.from("user_embeddings").insert({
fid,
summary,
embeddings,
is_subscribed: true
});
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("registerUser error", err);
return { success: false, error: err.message || err };
}
async registerAndSubscribeFID(fid: string, summary: any, embeddings: any) {
try {
const { data, error } = await this.supabase
.from("user_embeddings")
.insert({
fid,
summary,
embeddings,
is_subscribed: true,
});
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("registerUser error", err);
return { success: false, error: err.message || err };
}
}

async onlySubscribeFID(fid: string) {
try {
const { data, error } = await this.supabase.from("user_embeddings").update({ is_subscribed: true }).eq("fid", fid);
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("onlySubscribeFID error", err);
return { success: false, error: err.message || err };
}
async onlySubscribeFID(fid: string) {
try {
const { data, error } = await this.supabase
.from("user_embeddings")
.update({ is_subscribed: true })
.eq("fid", fid);
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("onlySubscribeFID error", err);
return { success: false, error: err.message || err };
}
}

async onlyRegisterFID(fid: string, summary: any, embeddings: any) {
try {
const { data, error } = await this.supabase.from("user_embeddings").insert({
fid,
summary,
embeddings,
is_subscribed: false
});
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("registerUser error", err);
return { success: false, error: err.message || err };
}
async onlyRegisterFID(fid: string, summary: any, embeddings: any) {
try {
const { data, error } = await this.supabase
.from("user_embeddings")
.insert({
fid,
summary,
embeddings,
is_subscribed: false,
});
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("registerUser error", err);
return { success: false, error: err.message || err };
}
}

async fetchSubscribedFIDs() {
try {
const { data, error } = await this.supabase.from("user_embeddings").select("fid").eq("is_subscribed", true);
if (error) throw error;
const fids = data.map((user: any) => user.fid);
return { success: true, data: fids };
} catch (err: any) {
console.error("fetchSubscribedFIDs error", err);
return { success: false, error: err.message || err, data: [] };
}
async fetchSubscribedFIDs() {
try {
const { data, error } = await this.supabase
.from("user_embeddings")
.select("fid")
.eq("is_subscribed", true);
if (error) throw error;
const fids = data.map((user: any) => user.fid);
return { success: true, data: fids };
} catch (err: any) {
console.error("fetchSubscribedFIDs error", err);
return { success: false, error: err.message || err, data: [] };
}
}

async checkFIDStatus(fid: number) {
try {
const { data, error } = await this.supabase.from("user_embeddings").select("fid, is_subscribed").eq("fid", fid).maybeSingle();
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("checkFIDStatus error", err);
return { success: false, error: err.message || err };
}
async checkFIDStatus(fid: number) {
try {
const { data, error } = await this.supabase
.from("user_embeddings")
.select("fid, is_subscribed")
.eq("fid", fid)
.maybeSingle();
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("checkFIDStatus error", err);
return { success: false, error: err.message || err };
}
}

async fetchAllFIDs() {
try {
const { data, error } = await this.supabase.from("user_embeddings").select("*");
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("fetchAllFIDs error", err);
return { success: false, error: err.message || err };
}
async fetchAllFIDs() {
try {
const { data, error } = await this.supabase
.from("user_embeddings")
.select("*");
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("fetchAllFIDs error", err);
return { success: false, error: err.message || err };
}
}

async fetchSimilarFIDs(cast_embeddings: any, match_threshold: number, match_count: number) {
try {
const { data, error } = await this.supabase.rpc("match_users_by_embedding", { query_embedding: cast_embeddings, match_threshold, match_count });
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("fetchSimilarFIDs error", err);
return { success: false, error: err.message || err };
}
async fetchSimilarFIDs(
cast_embeddings: any,
match_threshold: number,
match_count: number,
) {
try {
const { data, error } = await this.supabase.rpc(
"match_users_by_embedding",
{ query_embedding: cast_embeddings, match_threshold, match_count },
);
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("fetchSimilarFIDs error", err);
return { success: false, error: err.message || err };
}
}

async addCastReply(cast_hash: string) {
try {
const { data, error } = await this.supabase.from("cast_replies").insert([{ cast_hash }]);
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("addCastReply error", err);
return { success: false, error: err.message || err };
}
async addCastReply(cast_hash: string) {
try {
const { data, error } = await this.supabase
.from("cast_replies")
.insert([{ cast_hash }]);
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("addCastReply error", err);
return { success: false, error: err.message || err };
}
}

async isCastReplyExists(cast_hash: string) {
try {
const { data, error } = await this.supabase.from("cast_replies").select("cast_hash").eq("cast_hash", cast_hash).maybeSingle();
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("isCastReplyExists error", err);
return { success: false, error: err.message || err };
}
async isCastReplyExists(cast_hash: string) {
try {
const { data, error } = await this.supabase
.from("cast_replies")
.select("cast_hash")
.eq("cast_hash", cast_hash)
.maybeSingle();
if (error) throw error;
return { success: true, data };
} catch (err: any) {
console.error("isCastReplyExists error", err);
return { success: false, error: err.message || err };
}
}
}
Loading