Fix - APIBara integration breaking app

backend/.env.example

@@ -9,3 +9,7 @@ DB_PASS=
 DB_URL=
 DB_SSL=
 JWT_SECRET=""
+
+# gotten from https://www.apibara.com/ 
+DNA_TOKEN=""
+DNA_CLIENT_URL="dns:///sepolia.starknet.a5a.ch"

backend/README.md

@@ -10,4 +10,11 @@
 > Copy `.env.example` to `.env` file and update the postgresql credentials for production environment also set NODE_ENV to production if you want to run production, you can either use DB URL or set DB host,username,password and port with SSL for your DB connection.
 
 ### STEP 4
+> Get your Apibara DNA Token:
+> 1. Create an account at [Apibara](https://www.apibara.com/)
+> 2. Click on "New Indexer" to create an indexer
+> 3. Copy the DNA token provided
+> 4. Paste the token in your `.env` file as `DNA_TOKEN`
+
+### STEP 5
 > Start project with `npm start` on production environment and `npm run dev` on development environment.

backend/config/events.js

@@ -0,0 +1,7 @@
+export const events = {
+    NewEventAdded: "0x1", //replace with event identify
+    RegisteredForEvent: "0x2",
+    EventAttendanceMark: "0x3",
+    EndEventRegistration: "0x4",
+    RSVPForEvent: "0x5"
+};

backend/indexer/handlers.ts → backend/indexer/handlers.js

@@ -1,19 +1,12 @@
-import { 
-    NewEventAdded, 
-    RegisteredForEvent, 
-    EventAttendanceMark, 
-    EndEventRegistration, 
-    RSVPForEvent 
-} from "./types";
 import { FieldElement, v1alpha2 as starknet } from '@apibara/starknet';
 import Event from "../models/Event.js";
 import { uint256 } from 'starknet';
 import { hexToAscii } from "../utils/tohexAscii.js";
 
-export async function handleNewEventAdded(event: starknet.IEvent) {
-    const data = event.data!;
+export async function handleNewEventAdded(event) {
+    const data = event.data;
 
-    const eventDetails: NewEventAdded = {
+    const eventDetails = {
         name: hexToAscii(FieldElement.toHex(data[0]).toString()),
         event_id: parseInt(uint256
         .uint256ToBN({
@@ -36,10 +29,10 @@ export async function handleNewEventAdded(event: starknet.IEvent) {
     await Event.create(eventDetails);
 }
 
-export async function handleRegisteredForEvent(event: starknet.IEvent) {
-    const data = event.data!;
+export async function handleRegisteredForEvent(event) {
+    const data = event.data;
 
-    const registeredForEvent: RegisteredForEvent = {
+    const registeredForEvent = {
         event_id: parseInt(uint256
         .uint256ToBN({
           low: FieldElement.toBigInt(data[0]),
@@ -60,10 +53,10 @@ export async function handleRegisteredForEvent(event: starknet.IEvent) {
     await Event.registerUser(registeredForEvent.event_id, registeredForEvent.user_address);
 }
 
-export async function handleEventAttendanceMark(event: starknet.IEvent) {
-    const data = event.data!;
+export async function handleEventAttendanceMark(event) {
+    const data = event.data;
 
-    const eventAttendanceMark: EventAttendanceMark = {
+    const eventAttendanceMark = {
         event_id: parseInt(uint256
         .uint256ToBN({
           low: FieldElement.toBigInt(data[0]),
@@ -83,10 +76,10 @@ export async function handleEventAttendanceMark(event: starknet.IEvent) {
     await Event.markAttendance(eventAttendanceMark.event_id, eventAttendanceMark.user_address);
 }
 
-export async function handleEndEventRegistration(event: starknet.IEvent) {
-    const data = event.data!;
+export async function handleEndEventRegistration(event) {
+    const data = event.data;
 
-    const endEventRegistration: EndEventRegistration = {
+    const endEventRegistration = {
         event_id: parseInt(uint256
         .uint256ToBN({
           low: FieldElement.toBigInt(data[0]),
@@ -107,10 +100,10 @@ export async function handleEndEventRegistration(event: starknet.IEvent) {
     await Event.endRegistration(endEventRegistration.event_id);
 }
 
-export async function handleRSVPForEvent(event: starknet.IEvent) {
-    const data = event.data!;
+export async function handleRSVPForEvent(event) {
+    const data = event.data;
 
-    const rsvpForEvent: RSVPForEvent = {
+    const rsvpForEvent = {
         event_id: parseInt(uint256
         .uint256ToBN({
           low: FieldElement.toBigInt(data[0]),

backend/indexer/index.ts → backend/indexer/index.js

@@ -5,17 +5,17 @@ import {
   v1alpha2 as starknet,
   StarkNetCursor,
 } from '@apibara/starknet';
-import { events } from '../config/events';
+import { events } from '../config/events.js';
 import {
   handleNewEventAdded,
   handleRegisteredForEvent,
   handleEventAttendanceMark,
   handleEndEventRegistration,
   handleRSVPForEvent,
-} from './handlers';
+} from './handlers.js';
 
 const client = new StreamClient({
-  url: process.env.DNA_CLIENT_URL!,
+  url: process.env.DNA_CLIENT_URL,
   clientOptions: {
     'grpc.max_receive_message_length': 100 * 1024 * 1024, // 100MB
   },
@@ -26,7 +26,7 @@ const client = new StreamClient({
 const filter = Filter.create().withHeader({ weak: true });
 
 // Map your events to handlers
-const eventHandlers: Record<string, (event: starknet.IEvent) => Promise<void>> = {
+const eventHandlers = {
   [events.NewEventAdded]: handleNewEventAdded,
   [events.RegisteredForEvent]: handleRegisteredForEvent,
   [events.EventAttendanceMark]: handleEventAttendanceMark,
@@ -52,12 +52,12 @@ export async function startIndexer() {
 
   for await (const message of client) {
     if (message.message === 'data') {
-      const { data } = message.data!;
+      const { data } = message.data;
       for (const item of data) {
         const block = starknet.Block.decode(item);
         for (const event of block.events) {
           if (!event.event) continue;
-          const eventKey = FieldElement.toHex(event.event.keys![0]);
+          const eventKey = FieldElement.toHex(event.event.keys[0]);
           const handler = eventHandlers[eventKey];
           if (handler) {
             await handler(event.event);

backend/migrations/20241124121820_create_event_attendance_table.js

@@ -2,7 +2,7 @@
  * @param { import("knex").Knex } knex
  * @returns { Promise<void> }
  */
-exports.up = function(knex) {
+export const up = function(knex) {
   return knex.schema.createTable("event_attendance", function (table) {
     table.increments("id").primary();
     table.string("event_id").notNullable();
@@ -18,6 +18,6 @@ exports.up = function(knex) {
  * @param { import("knex").Knex } knex
  * @returns { Promise<void> }
  */
-exports.down = function(knex) {
+export const down = function(knex) {
   return knex.schema.dropTableIfExists("event_attendance");
 };

backend/migrations/20241124121820_create_event_registrations_table.js

@@ -2,7 +2,7 @@
  * @param { import("knex").Knex } knex
  * @returns { Promise<void> }
  */
-exports.up = function(knex) {
+export const up = function(knex) {
   return knex.schema.createTable("event_registrations", function (table) {
     table.increments("id").primary();
     table.string("event_id").notNullable();
@@ -19,6 +19,6 @@ exports.up = function(knex) {
  * @param { import("knex").Knex } knex
  * @returns { Promise<void> }
  */
-exports.down = function(knex) {
+export const down = function(knex) {
   return knex.schema.dropTableIfExists("event_registrations");
 };

backend/migrations/20241124121820_create_event_rsvps_table.js

@@ -2,7 +2,7 @@
  * @param { import("knex").Knex } knex
  * @returns { Promise<void> }
  */
-exports.up = function(knex) {
+export const up = function(knex) {
   return knex.schema.createTable("event_rsvps", function (table) {
     table.increments("id").primary();
     table.string("event_id").notNullable();
@@ -18,6 +18,6 @@ exports.up = function(knex) {
  * @param { import("knex").Knex } knex
  * @returns { Promise<void> }
  */
-exports.down = function(knex) {
+export const down = function(knex) {
   return knex.schema.dropTableIfExists("event_rsvps");
 };