1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556
import { serve } from "https://deno.land/std@0.167.0/http/server.ts";import { IServerExtension } from "./extensions/extension.ts";import { ServerCore } from "./server_core.ts";
export type ServerOpts = {  port?: number;  hostname?: string;};
/** * An extensible Earthstar server able to synchronise with other peers. * * A server's functionality can be extended using extensions of type `IServerExtension`. * * ```ts * const server = new Server([ *  new ExtensionKnownShares({ *    knownSharesPath: "./known_shares.json", *      onCreateReplica: (shareAddress) => { *        return new Earthstar.Replica({ *          driver: new ReplicaDriverFs(shareAddress, "./share_data"), *         }); *      }, *    }), *  new ExtensionSyncWeb(), * ]); * ``` */export class Server {  private core: ServerCore;  private abortController: AbortController;  private server: 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[], opts?: ServerOpts) {    this.core = new ServerCore(extensions);
    this.abortController = new AbortController();
    this.server = serve(this.core.handler.bind(this.core), {      port: opts?.port,      hostname: opts?.hostname,      signal: this.abortController.signal,    });  }
  async close() {    this.abortController.abort();
    await this.server;  }}