1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
import { Peer } from "../peer/peer.ts";import { IServerExtension } from "./extensions/extension.ts";
/** The core server logic. Combine this with a HTTP framework to create a fully-fledged server. */export class ServerCore {  private extensions: IServerExtension[];  private peer: Peer;  private isReady: Promise<void>;
  /**   * Create a new server with an array of extensions.   * @param extensions - The extensions used by the server. Extensions will be registered in the order you provide them in, as one extension may depend on the actions of another. For example, the `ExtensionServeContent` may rely on a replica created by `ExtensionKnownShares`.   */  constructor(extensions: IServerExtension[]) {    this.peer = new Peer();
    this.extensions = extensions;
    this.isReady = this.registerExtensions();
    console.log("Your server is running.");  }
  private async registerExtensions() {    // Extensions must be registered sequentially, one-by-one,    // As later extensions may depend on the actions of previous ones    // e.g. The serve content extension using a share added by the known shares extension    for (const extension of this.extensions) {      await extension.register(this.peer);    }  }
  async handler(req: Request): Promise<Response> {    await this.isReady;
    for (const extension of this.extensions) {      const response = await extension.handler(req);
      if (response) {        return response;      }    }
    return new Response("Not found", { status: 404 });  }}