Module build failed: UnhandledSchemeError: Reading from "node:process" is not handled by plugins (Unhandled scheme).
Webpack supports "data:" and "file:" URIs by default.
You may need an additional plugin to handle "node:" URIs.
Import trace for requested module:
node:process

Module build failed: UnhandledSchemeError: Reading from "node:process" is not handled by plugins (Unhandled scheme).
Webpack supports "data:" and "file:" URIs by default.
You may need an additional plugin to handle "node:" URIs.
Import trace for requested module:
node:process

import { Hono } from 'hono'

export default class Counter {
  value: number = 0
  state: DurableObjectState
  app: Hono = new Hono()

  constructor(state: DurableObjectState) {
    this.state = state
    this.state.blockConcurrencyWhile(async () => {
      const stored = await this.state.storage?.get<number>('value')
      this.value = stored || 0
    })

    this.app.get('/increment', async (c) => {
      const currentValue = ++this.value
      await this.state.storage?.put('value', this.value)
      return c.text(currentValue.toString())
    })

    this.app.get('/decrement', async (c) => {
      const currentValue = --this.value
      await this.state.storage?.put('value', this.value)
      return c.text(currentValue.toString())
    })

    this.app.get('/', async (c) => {
      return c.text(this.value.toString())
    })
  }

  async fetch(request: Request) {
    return this.app.fetch(request)
  }
}

import { Hono } from 'hono'

export default class Counter {
  value: number = 0
  state: DurableObjectState
  app: Hono = new Hono()

  constructor(state: DurableObjectState) {
    this.state = state
    this.state.blockConcurrencyWhile(async () => {
      const stored = await this.state.storage?.get<number>('value')
      this.value = stored || 0
    })

    this.app.get('/increment', async (c) => {
      const currentValue = ++this.value
      await this.state.storage?.put('value', this.value)
      return c.text(currentValue.toString())
    })

    this.app.get('/decrement', async (c) => {
      const currentValue = --this.value
      await this.state.storage?.put('value', this.value)
      return c.text(currentValue.toString())
    })

    this.app.get('/', async (c) => {
      return c.text(this.value.toString())
    })
  }

  async fetch(request: Request) {
    return this.app.fetch(request)
  }
}

import durableObject from "./durable-object";

export const app = new Hono();
app.route("/durable-object", durableObject);

import durableObject from "./durable-object";

export const app = new Hono();
app.route("/durable-object", durableObject);

Argument of type 'typeof Counter' is not assignable to parameter of type 'Hono<Env, Schema, string>'.
  Type 'typeof Counter' is missing the following properties from type 'Hono<Env, Schema, string>': #private, get, post, put, and 25 more.ts(2345)
⚠ Error (TS2345)  | 
Argument of type 
 is not assignable to parameter of type 
 .
   

Type 
 is missing the following properties from type 
 :
#private, get, post, put, and 25 more.

Argument of type 'typeof Counter' is not assignable to parameter of type 'Hono<Env, Schema, string>'.
  Type 'typeof Counter' is missing the following properties from type 'Hono<Env, Schema, string>': #private, get, post, put, and 25 more.ts(2345)
⚠ Error (TS2345)  | 
Argument of type 
 is not assignable to parameter of type 
 .
   

Type 
 is missing the following properties from type 
 :
#private, get, post, put, and 25 more.

const subquery = db
  .select({
    id: myTable1.id,
  })
  .from(myTable1)
  .as("subquery");

const query = db
  .select({
    id: myTable2.id,
    table1Ids: sql`array(${subquery})`.as("table1Ids")
    // Error. Syntax error at or near "subquery" 
  })
  .from(myTable2)
  .leftJoin(
    subquery,
    eq(subquery.id, myTable2.table1Id)
  );

const subquery = db
  .select({
    id: myTable1.id,
  })
  .from(myTable1)
  .as("subquery");

const query = db
  .select({
    id: myTable2.id,
    table1Ids: sql`array(${subquery})`.as("table1Ids")
    // Error. Syntax error at or near "subquery" 
  })
  .from(myTable2)
  .leftJoin(
    subquery,
    eq(subquery.id, myTable2.table1Id)
  );

import { sql } from "drizzle-orm";
import { index, jsonb, pgTable } from "drizzle-orm/pg-core";

export const users = pgTable("users", {
  metadata: jsonb("metadata").$type<Record<string, any>>(),
}, t => ({
  ginIndex: index("gin_idx").on(t.metadata).using(sql`gin`),
  ginIndex2: index("gin_idx_2").on(t.metadata).using(sql`GIN ((metadata->'name'))`),
}));

import { sql } from "drizzle-orm";
import { index, jsonb, pgTable } from "drizzle-orm/pg-core";

export const users = pgTable("users", {
  metadata: jsonb("metadata").$type<Record<string, any>>(),
}, t => ({
  ginIndex: index("gin_idx").on(t.metadata).using(sql`gin`),
  ginIndex2: index("gin_idx_2").on(t.metadata).using(sql`GIN ((metadata->'name'))`),
}));

CREATE TABLE IF NOT EXISTS "users" (
    "metadata" jsonb
);
--> statement-breakpoint
CREATE INDEX IF NOT EXISTS "users_metadata_gin_idx" ON "users" ("metadata");--> statement-breakpoint
CREATE INDEX IF NOT EXISTS "users_metadata_name_gin_idx" ON "users" ("metadata");

CREATE TABLE IF NOT EXISTS "users" (
    "metadata" jsonb
);
--> statement-breakpoint
CREATE INDEX IF NOT EXISTS "users_metadata_gin_idx" ON "users" ("metadata");--> statement-breakpoint
CREATE INDEX IF NOT EXISTS "users_metadata_name_gin_idx" ON "users" ("metadata");

  userIdReference: foreignKey(
    {
      columns: [table.userId],
      foreignColumns: [users.userId],
      name: "accounts_user_id_fk",
    },
  ),

  userIdReference: foreignKey(
    {
      columns: [table.userId],
      foreignColumns: [users.userId],
      name: "accounts_user_id_fk",
    },
  ),

userId: integer('user_id').references(() => users.id, { onDelete: 'cascade' })

userId: integer('user_id').references(() => users.id, { onDelete: 'cascade' })

app.get("/test", async c => {
    const message = `Test message. Random number: ${Math.floor(Math.random() * 100)}`;
    await c.env.WEBSITE_QUEUE.send({
        body: message,
    });

    return c.json({ success: `Queued up this message: ${message}` });
});

app.get("/test", async c => {
    const message = `Test message. Random number: ${Math.floor(Math.random() * 100)}`;
    await c.env.WEBSITE_QUEUE.send({
        body: message,
    });

    return c.json({ success: `Queued up this message: ${message}` });
});

export default {
    fetch: app.fetch,
    async queue(batch: MessageBatch<{ body: string }>, env: Environment) {
        for (const message of batch.messages) {
            console.log(
                `Consuming message: ${JSON.stringify(message.body, null, 2)}`
            );
        }
    },
};

export default {
    fetch: app.fetch,
    async queue(batch: MessageBatch<{ body: string }>, env: Environment) {
        for (const message of batch.messages) {
            console.log(
                `Consuming message: ${JSON.stringify(message.body, null, 2)}`
            );
        }
    },
};

import {
  FindManyOptions,
  FindOneOptions,
  FindOperator,
  FindOptionsSelect,
  FindOptionsWhere,
  OrderByCondition
} from "typeorm";

import { FindOptionsOrder } from "typeorm/find-options/FindOptionsOrder";
import { FindOptionsRelations } from "typeorm/find-options/FindOptionsRelations";

import {
  FindManyOptions,
  FindOneOptions,
  FindOperator,
  FindOptionsSelect,
  FindOptionsWhere,
  OrderByCondition
} from "typeorm";

import { FindOptionsOrder } from "typeorm/find-options/FindOptionsOrder";
import { FindOptionsRelations } from "typeorm/find-options/FindOptionsRelations";

-- Enable row-level security on the messages table
ALTER TABLE messages ENABLE ROW LEVEL SECURITY;

-- Create a policy that allows users to access only their own messages
CREATE POLICY messages_user_policy
  FOR ALL
  USING (current_setting('app.user_id')::text = chat_id);

-- Set the current user ID when connecting to the database
SET app.user_id = 'user1';

-- Now, when querying the messages table, only messages belonging to 'user1' will be returned
SELECT * FROM messages;

-- Enable row-level security on the messages table
ALTER TABLE messages ENABLE ROW LEVEL SECURITY;

-- Create a policy that allows users to access only their own messages
CREATE POLICY messages_user_policy
  FOR ALL
  USING (current_setting('app.user_id')::text = chat_id);

-- Set the current user ID when connecting to the database
SET app.user_id = 'user1';

-- Now, when querying the messages table, only messages belonging to 'user1' will be returned
SELECT * FROM messages;

create unique index sso_domains_domain_idx on auth.sso_domains using btree (lower(domain)) tablespace pg_default;

create unique index sso_domains_domain_idx on auth.sso_domains using btree (lower(domain)) tablespace pg_default;

export const ssoDomains = authSchema.table(
  "sso_domains",
    {
      domain: text("domain").notNull(),
    },
    table => ({
      ssoDomainsDomainIdx: uniqueIndex("sso_domains_domain_idx").on(table.domain).where(sql`lower(${table.domain.name})`),
    })
);

export const ssoDomains = authSchema.table(
  "sso_domains",
    {
      domain: text("domain").notNull(),
    },
    table => ({
      ssoDomainsDomainIdx: uniqueIndex("sso_domains_domain_idx").on(table.domain).where(sql`lower(${table.domain.name})`),
    })
);

await db.transaction(async tx => {
  const hasUser = await tx.query.users.findFirst(...); 
  if (hasUser) {
    throw new Error("User already exists"); 
  }
  // ^ This doesn't work right?

  const hasToken = await tx.query.token.findFirst(...);
  if (hasToken) {
    throw new Error("Token already exists");
  } 
  // ^ Neither does this?

  const token = await tx.insert(token).values(...);
});

await db.transaction(async tx => {
  const hasUser = await tx.query.users.findFirst(...); 
  if (hasUser) {
    throw new Error("User already exists"); 
  }
  // ^ This doesn't work right?

  const hasToken = await tx.query.token.findFirst(...);
  if (hasToken) {
    throw new Error("Token already exists");
  } 
  // ^ Neither does this?

  const token = await tx.insert(token).values(...);
});