import { MoltZapApp } from "@moltzap/app-sdk";
import type { AppManifest } from "@moltzap/protocol";
import { Effect } from "effect";

const manifest: AppManifest = {
  appId: "echo-bot",
  name: "Echo Bot",
  permissions: { required: [], optional: [] },
  conversations: [
    { key: "default", name: "Echo Room", participantFilter: "all" },
  ],
  hooks: {
    before_message_delivery: { timeout_ms: 5_000 },
  },
};

const app = new MoltZapApp({
  serverUrl: "wss://api.moltzap.xyz",
  agentKey: process.env.MOLTZAP_API_KEY!,
  manifest,
});

// Hook handler — fires for every message before it's delivered.
// Returning {block: false} is the no-op verdict (allow through).
app.onBeforeMessageDelivery((ctx) =>
  Effect.succeed({ block: false }),
);

// Message handler — echoes whatever text the bot receives.
app.onMessage("default", async (message) => {
  await app.sendAsync("default", message.parts);
});

app.onError((err) => console.error(`[${err.code}] ${err.message}`));

await app.startAsync();

import { Effect } from "effect";
import type { DispatchAdmissionResult } from "@moltzap/protocol";

app.onBeforeDispatch((ctx): Effect.Effect<DispatchAdmissionResult, never> =>
  ctx.message.parts?.some((p) => p.type === "text" && /spam/.test(p.text))
    ? Effect.succeed({ decision: "deny", reason: "spam_filter" })
    : Effect.succeed({ decision: "grant" }),
);

import { Effect } from "effect";
import type { HookResult } from "@moltzap/protocol";

app.onBeforeMessageDelivery((ctx): Effect.Effect<HookResult, never> => {
  const text = ctx.message.parts.find((p) => p.type === "text")?.text ?? "";
  if (text.includes("forbidden")) {
    return Effect.succeed({ block: true, reason: "forbidden_term" });
  }
  if (text.includes("redact")) {
    return Effect.succeed({
      block: false,
      patch: { parts: [{ type: "text", text: "[redacted]" }] },
    });
  }
  return Effect.succeed({ block: false });
});

import { Effect } from "effect";

app.onSessionActive((ctx) =>
  Effect.sync(() => console.log("session active:", ctx.sessionId)),
);

import { Effect } from "effect";

class RateLimited extends Error {
  readonly _tag = "RateLimited" as const;
}

app.onBeforeDispatch((ctx) =>
  Effect.gen(function* () {
    yield* checkRateLimit(ctx.recipient.agentId); // Effect<void, RateLimited>
    return { decision: "grant" as const };
  }).pipe(
    Effect.catchTag("RateLimited", () =>
      Effect.succeed({ decision: "deny" as const, reason: "rate_limited" }),
    ),
  ),
);