+
Transactions
diff --git a/src/components/ui/BarList.tsx b/src/components/ui/BarList.tsx
index 8fd26af..36d457d 100644
--- a/src/components/ui/BarList.tsx
+++ b/src/components/ui/BarList.tsx
@@ -4,7 +4,7 @@ import { Text } from "@radix-ui/themes";
import Link from "next/link";
import { themeColors } from "./utils";
-const getWidthsFromValues = (dataValues: number[]) => {
+export const getWidthsFromValues = (dataValues: number[]) => {
let maxValue = Number.NEGATIVE_INFINITY;
dataValues.forEach((value) => {
maxValue = Math.max(maxValue, value);
diff --git a/src/env.ts b/src/env.ts
index be0ef28..3d3273e 100644
--- a/src/env.ts
+++ b/src/env.ts
@@ -5,6 +5,11 @@ export const env = createEnv({
server: {
DATABASE_PATH: z.string().min(1),
CHAINHOOKS_API_TOKEN: z.string().min(1),
+ CRON_API_TOKEN: z.string().min(1),
+ TWITTER_API_KEY: z.string().min(1),
+ TWITTER_API_SECRET_KEY: z.string().min(1),
+ TWITTER_ACCESS_TOKEN: z.string().min(1),
+ TWITTER_ACCESS_TOKEN_SECRET: z.string().min(1),
},
client: {
NEXT_PUBLIC_BASE_URL: z.string().min(1),
diff --git a/src/lib/twitter.ts b/src/lib/twitter.ts
new file mode 100644
index 0000000..24a292b
--- /dev/null
+++ b/src/lib/twitter.ts
@@ -0,0 +1,38 @@
+import { env } from "@/env";
+import { EUploadMimeType, TwitterApi } from "twitter-api-v2";
+
+const twitterClient = new TwitterApi({
+ appKey: env.TWITTER_API_KEY,
+ appSecret: env.TWITTER_API_SECRET_KEY,
+ accessToken: env.TWITTER_ACCESS_TOKEN,
+ accessSecret: env.TWITTER_ACCESS_TOKEN_SECRET,
+});
+
+export const sendTweet = async ({
+ message,
+ images,
+}: {
+ message: string;
+ images?: string[];
+}) => {
+ if (env.TWITTER_API_KEY === "dev") {
+ console.log("Debug Send Tweet:\n", message);
+ return;
+ }
+
+ const mediaIds = images
+ ? await Promise.all(
+ images.map(async (image) => {
+ const img = await fetch(image).then((res) => res.arrayBuffer());
+ return twitterClient.v1.uploadMedia(Buffer.from(img), {
+ mimeType: EUploadMimeType.Png,
+ });
+ }),
+ )
+ : [];
+
+ await twitterClient.v2.tweet({
+ text: message,
+ media: { media_ids: mediaIds },
+ });
+};
diff --git a/src/middleware.ts b/src/middleware.ts
index b637660..65d01ac 100644
--- a/src/middleware.ts
+++ b/src/middleware.ts
@@ -3,19 +3,40 @@ import { env } from "./env";
export const config = {
// Protect the entire /api/chainhooks/* with a bearer token
- matcher: "/api/chainhooks/:function*",
+ // Protect the entire /api/cron/* with a bearer token
+ matcher: ["/api/chainhooks/:function*", "/api/cron/:function*"],
};
export function middleware(request: NextRequest) {
- const authorization = request.headers.get("Authorization") || "";
- const [scheme, token] = authorization.split(" ");
+ const endpoint = request.url.split("/");
+ endpoint.splice(0, 3);
- if (scheme !== "Bearer" || token !== env.CHAINHOOKS_API_TOKEN) {
+ // Should never happen
+ if (endpoint[0] !== "api") {
return Response.json(
- { success: false, message: "authentication failed" },
- { status: 401 },
+ { success: false, message: "internal server error" },
+ { status: 500 },
);
}
+ const authorization = request.headers.get("Authorization") || "";
+ const [scheme, token] = authorization.split(" ");
+
+ if (endpoint[1] === "chainhooks") {
+ if (scheme !== "Bearer" || token !== env.CHAINHOOKS_API_TOKEN) {
+ return Response.json(
+ { success: false, message: "authentication failed" },
+ { status: 401 },
+ );
+ }
+ } else if (endpoint[1] === "cron") {
+ if (scheme !== "Bearer" || token !== env.CRON_API_TOKEN) {
+ return Response.json(
+ { success: false, message: "authentication failed" },
+ { status: 401 },
+ );
+ }
+ }
+
return NextResponse.next();
}