Documentação para Desenvolvedores

1/**
2 * Sweetly Bot - TypeScript / Node.js (5 minutos)
3 * Instalação: npm install socket.io-client
4 */
5import { io, Socket } from "socket.io-client";
6
7interface ChatMessage {
8  readonly id: string;
9  readonly channelId: string;
10  readonly userId: string;
11  readonly username: string;
12  readonly content: string;
13  readonly isSystem: boolean;
14  readonly createdAt: string;
15}
16
17interface TipEvent {
18  readonly id: string;
19  readonly donorAddress: string;
20  readonly amountUsd: number;
21  readonly message?: string;
22  readonly txHash: string;
23}
24
25const SWEETLY_HOST = process.env.SWEETLY_HOST ?? "https://sweetly.live";
26const CHANNEL_ID = process.env.CHANNEL_ID ?? "seu-channel-uuid-aqui";
27
28// Inicializa a conexão com transporte puro WebSocket para latência mínima
29const socket: Socket = io(SWEETLY_HOST, {
30  transports: ["websocket"],
31  reconnection: true,
32  reconnectionAttempts: 15,
33  reconnectionDelay: 1000,
34  reconnectionDelayMax: 5000,
35});
36
37socket.on("connect", () => {
38  console.log("⚡ [Sweetly Bot] Conexão estabelecida:", socket.id);
39
40  // Ingressa no canal especificado
41  socket.emit("channel:join", { channelId: CHANNEL_ID }, () => {
42    console.log(`📡 Bot conectado e ouvindo a sala: ${CHANNEL_ID}`);
43    sendMessage("🤖 SweetlyBot v1.0 online e monitorando o chat!");
44  });
45});
46
47// Listener de novas mensagens no chat
48socket.on("message:new", (msg: ChatMessage) => {
49  if (msg.isSystem || msg.username === "SweetlyBot") return;
50
51  const content = msg.content.trim();
52  console.log(`[${msg.username}]: ${content}`);
53
54  if (content === "!ping") {
55    sendMessage(`🏓 Pong! Latência estimada: ${socket.io.engine?.pingInterval}ms`);
56  } else if (content === "!votar") {
57    sendMessage("⭐ Fortaleça o criador votando no ranking Spotlight pelo botão Votar!");
58  } else if (content === "!ajuda") {
59    sendMessage("📖 Comandos: !ping, !votar, !stats, !contrato");
60  } else if (content === "!contrato") {
61    sendMessage("⛓️ Assinaturas via USDC na rede Base: 5 USDC / 30 dias!");
62  }
63});
64
65// Listener de Gorjetas Web3 (USDC na Base)
66socket.on("tip:new", (tip: TipEvent) => {
67  console.log("💰 Nova gorjeta onchain detectada:", tip.txHash);
68  sendMessage(
69    `💎 ${tip.donorAddress.slice(0, 6)}... enviou US$ ${tip.amountUsd.toFixed(2)} em USDC! "${tip.message ?? ""}"`
70  );
71});
72
73// Listener de Votos para o Spotlight
74socket.on("vote:cast", (vote: { channelId: string; amount: number; totalVotes: number }) => {
75  console.log(`⭐ + ${vote.amount} votos computados. Total: ${vote.totalVotes}`);
76});
77
78// Tratamento de erros do sistema
79socket.on("system:error", (err: { code: string; message: string }) => {
80  console.error("⚠️ [Sweetly Error]:", err.code, err.message);
81});
82
83function sendMessage(content: string) {
84  socket.emit("message:send", {
85    channelId: CHANNEL_ID,
86    content,
87  });
88}

1[
2  {
3    "type": "constructor",
4    "inputs": [
5      {
6        "name": "usdcAddress",
7        "type": "address",
8        "internalType": "address"
9      },
10      {
11        "name": "keeperAddress",
12        "type": "address",
13        "internalType": "address"
14      }
15    ],
16    "stateMutability": "nonpayable"
17  },
18  {
19    "type": "error",
20    "name": "InvalidAddress",
21    "inputs": []
22  },
23  {
24    "type": "error",
25    "name": "OnlyKeeper",
26    "inputs": []
27  },
28  {
29    "type": "error",
30    "name": "OutsideRenewalWindow",
31    "inputs": []
32  },
33  {
34    "type": "error",
35    "name": "PaymentFailed",
36    "inputs": []
37  },
38  {
39    "type": "event",
40    "name": "Subscribed",
41    "inputs": [
42      {
43        "name": "subscriber",
44        "type": "address",
45        "indexed": true,
46        "internalType": "address"
47      },
48      {
49        "name": "creator",
50        "type": "address",
51        "indexed": true,
52        "internalType": "address"
53      },
54      {
55        "name": "expiresAt",
56        "type": "uint256",
57        "indexed": false,
58        "internalType": "uint256"
59      }
60    ],
61    "anonymous": false
62  },
63  {
64    "type": "event",
65    "name": "Renewed",
66    "inputs": [
67      {
68        "name": "subscriber",
69        "type": "address",
70        "indexed": true,
71        "internalType": "address"
72      },
73      {
74        "name": "creator",
75        "type": "address",
76        "indexed": true,
77        "internalType": "address"
78      },
79      {
80        "name": "expiresAt",
81        "type": "uint256",
82        "indexed": false,
83        "internalType": "uint256"
84      }
85    ],
86    "anonymous": false
87  },
88  {
89    "type": "event",
90    "name": "Cancelled",
91    "inputs": [
92      {
93        "name": "subscriber",
94        "type": "address",
95        "indexed": true,
96        "internalType": "address"
97      },
98      {
99        "name": "creator",
100        "type": "address",
101        "indexed": true,
102        "internalType": "address"
103      }
104    ],
105    "anonymous": false
106  },
107  {
108    "type": "function",
109    "name": "cancel",
110    "inputs": [
111      {
112        "name": "creator",
113        "type": "address",
114        "internalType": "address"
115      }
116    ],
117    "outputs": [],
118    "stateMutability": "nonpayable"
119  },
120  {
121    "type": "function",
122    "name": "isSubscribed",
123    "inputs": [
124      {
125        "name": "subscriber",
126        "type": "address",
127        "internalType": "address"
128      },
129      {
130        "name": "creator",
131        "type": "address",
132        "internalType": "address"
133      }
134    ],
135    "outputs": [
136      {
137        "name": "",
138        "type": "bool",
139        "internalType": "bool"
140      }
141    ],
142    "stateMutability": "view"
143  },
144  {
145    "type": "function",
146    "name": "keeper",
147    "inputs": [],
148    "outputs": [
149      {
150        "name": "",
151        "type": "address",
152        "internalType": "address"
153      }
154    ],
155    "stateMutability": "view"
156  },
157  {
158    "type": "function",
159    "name": "renew",
160    "inputs": [
161      {
162        "name": "subscriber",
163        "type": "address",
164        "internalType": "address"
165      },
166      {
167        "name": "creator",
168        "type": "address",
169        "internalType": "address"
170      }
171    ],
172    "outputs": [],
173    "stateMutability": "nonpayable"
174  },
175  {
176    "type": "function",
177    "name": "subscribe",
178    "inputs": [
179      {
180        "name": "creator",
181        "type": "address",
182        "internalType": "address"
183      }
184    ],
185    "outputs": [],
186    "stateMutability": "nonpayable"
187  },
188  {
189    "type": "function",
190    "name": "subscriptions",
191    "inputs": [
192      {
193        "name": "subscriber",
194        "type": "address",
195        "internalType": "address"
196      },
197      {
198        "name": "creator",
199        "type": "address",
200        "internalType": "address"
201      }
202    ],
203    "outputs": [
204      {
205        "name": "expiresAt",
206        "type": "uint256",
207        "internalType": "uint256"
208      }
209    ],
210    "stateMutability": "view"
211  },
212  {
213    "type": "function",
214    "name": "usdc",
215    "inputs": [],
216    "outputs": [
217      {
218        "name": "",
219        "type": "address",
220        "internalType": "contract IERC20"
221      }
222    ],
223    "stateMutability": "view"
224  }
225]

1import { createPublicClient, createWalletClient, custom, http, parseUnits } from "viem";
2import { base } from "viem/chains";
3import { subscriptionManagerAbi, subscriptionManagerAddresses, usdcAddresses } from "@sweetly/contracts";
4
5// 1. Configuração do cliente na Base Mainnet (Chain ID 8453)
6const publicClient = createPublicClient({
7  chain: base,
8  transport: http("https://mainnet.base.org"),
9});
10
11const walletClient = createWalletClient({
12  chain: base,
13  transport: custom(window.ethereum),
14});
15
16const USDC_ADDRESS = usdcAddresses[base.id];
17const MANAGER_ADDRESS = subscriptionManagerAddresses[base.id];
18const MONTHLY_PRICE = parseUnits("5", 6); // 5 USDC (6 decimais = 5_000_000)
19
20export async function subscribeToCreator(creatorAddress: `0x${string}`) {
21  const [account] = await walletClient.getAddresses();
22  if (!account) throw new Error("Carteira nao conectada");
23
24  // Passo 1: Aprovar o SubscriptionManager a movimentar 5 USDC
25  const erc20Abi = [
26    {
27      name: "approve",
28      type: "function",
29      inputs: [{ name: "spender", type: "address" }, { name: "amount", type: "uint256" }],
30      outputs: [{ name: "", type: "bool" }],
31      stateMutability: "nonpayable",
32    },
33  ] as const;
34
35  console.log("1. Aprovando transferencia de 5 USDC...");
36  const approveHash = await walletClient.writeContract({
37    address: USDC_ADDRESS,
38    abi: erc20Abi,
39    functionName: "approve",
40    args: [MANAGER_ADDRESS, MONTHLY_PRICE],
41    account,
42  });
43
44  await publicClient.waitForTransactionReceipt({ hash: approveHash });
45  console.log("Aprovado com sucesso!");
46
47  // Passo 2: Executar a assinatura
48  console.log("2. Chamando subscribe(creator)...");
49  const subscribeHash = await walletClient.writeContract({
50    address: MANAGER_ADDRESS,
51    abi: subscriptionManagerAbi,
52    functionName: "subscribe",
53    args: [creatorAddress],
54    account,
55  });
56
57  const receipt = await publicClient.waitForTransactionReceipt({ hash: subscribeHash });
58  console.log("🎉 Assinatura confirmada no bloco:", receipt.blockNumber);
59  return receipt;
60}

// Padrão resiliente para bots de produção:
const socket = io("https://sweetly.live", {
  transports: ["websocket"],
  reconnection: true,
  reconnectionAttempts: Infinity,
  reconnectionDelay: 1000,
  reconnectionDelayMax: 10000,
  randomizationFactor: 0.5, // Adiciona jitter para evitar tempestades de reconexão
});

socket.on("connect", () => {
  // Sempre reingressar na sala após reconectar
  socket.emit("channel:join", { channelId: CURRENT_CHANNEL });
});