import { WorkerEntrypoint } from 'cloudflare:workers';
import { WorkerDO } from './worker-do';

export { WorkerDO };

export default class Worker extends WorkerEntrypoint<Env> {
    async fetch(request: Request) {
        return new Response('Hello');
    }
    async getWorkerRPC(doId: string) {
        const id = this.env.WORKER_DO.idFromName(doId);
        const stub = this.env.WORKER_DO.get(id);
        return stub.getRpcTarget();
    }
}

import { WorkerEntrypoint } from 'cloudflare:workers';
import { WorkerDO } from './worker-do';

export { WorkerDO };

export default class Worker extends WorkerEntrypoint<Env> {
    async fetch(request: Request) {
        return new Response('Hello');
    }
    async getWorkerRPC(doId: string) {
        const id = this.env.WORKER_DO.idFromName(doId);
        const stub = this.env.WORKER_DO.get(id);
        return stub.getRpcTarget();
    }
}

import { DurableObject, RpcTarget } from 'cloudflare:workers';

type Product = { id: string; name: string };

export class WorkerDO extends DurableObject<Env> {
    products: Product[] = [];

    constructor(ctx: DurableObjectState, env: Env) {
        super(ctx, env);

        ctx.blockConcurrencyWhile(async () => {
            this.products = (await ctx.storage.get('products')) || [];
        });
    }

    async getProducts() {
        return this.products;
    }

    async getProductById(id: string) {
        return this.products.find((product) => product.id === id);
    }

    async addProduct(productData: Omit<Product, 'id'>) {
        const newProduct: Product = { ...productData, id: crypto.randomUUID() };
        this.products.push(newProduct);
        await this.ctx.storage.put('products', this.products);
        return newProduct;
    }

    async deleteProduct(productId: string): Promise<boolean> {
        const initialLength = this.products.length;
        this.products = this.products.filter((p) => p.id !== productId);
        if (this.products.length === initialLength) return false; // Not found
        await this.ctx.storage.put('products', this.products);
        return true;
    }

    private rpcTarget = class extends RpcTarget {
        private stub: WorkerDO;

        constructor(stub: WorkerDO) {
            super();
            this.stub = stub;
        }
        async getProducts() {
            return this.stub.getProducts();
        }
        async getProductById(id: string) {
            return this.stub.getProductById(id);
        }
        async addProduct(productData: Omit<Product, 'id'>) {
            return this.stub.addProduct(productData);
        }
        async deleteProduct(productId: string) {
            return this.stub.deleteProduct(productId);
        }
    };

    async getRpcTarget() {
        return new this.rpcTarget(this);
    }
}

import { DurableObject, RpcTarget } from 'cloudflare:workers';

type Product = { id: string; name: string };

export class WorkerDO extends DurableObject<Env> {
    products: Product[] = [];

    constructor(ctx: DurableObjectState, env: Env) {
        super(ctx, env);

        ctx.blockConcurrencyWhile(async () => {
            this.products = (await ctx.storage.get('products')) || [];
        });
    }

    async getProducts() {
        return this.products;
    }

    async getProductById(id: string) {
        return this.products.find((product) => product.id === id);
    }

    async addProduct(productData: Omit<Product, 'id'>) {
        const newProduct: Product = { ...productData, id: crypto.randomUUID() };
        this.products.push(newProduct);
        await this.ctx.storage.put('products', this.products);
        return newProduct;
    }

    async deleteProduct(productId: string): Promise<boolean> {
        const initialLength = this.products.length;
        this.products = this.products.filter((p) => p.id !== productId);
        if (this.products.length === initialLength) return false; // Not found
        await this.ctx.storage.put('products', this.products);
        return true;
    }

    private rpcTarget = class extends RpcTarget {
        private stub: WorkerDO;

        constructor(stub: WorkerDO) {
            super();
            this.stub = stub;
        }
        async getProducts() {
            return this.stub.getProducts();
        }
        async getProductById(id: string) {
            return this.stub.getProductById(id);
        }
        async addProduct(productData: Omit<Product, 'id'>) {
            return this.stub.addProduct(productData);
        }
        async deleteProduct(productId: string) {
            return this.stub.deleteProduct(productId);
        }
    };

    async getRpcTarget() {
        return new this.rpcTarget(this);
    }
}