about summary refs log tree commit diff
path: root/assets/src/models
diff options
context:
space:
mode:
authorMel <einebeere@gmail.com>2022-02-19 20:00:38 +0100
committerMel <einebeere@gmail.com>2022-02-19 20:00:38 +0100
commitbf1450799df0deb424a9675be89e13c29e3620d7 (patch)
tree6a5f2f7559c5946058deadf8375f6609485a3d3f /assets/src/models
parent5384c34952b031995ecb8aa58d72954b0c685e18 (diff)
downloadrook-bf1450799df0deb424a9675be89e13c29e3620d7.tar.zst
rook-bf1450799df0deb424a9675be89e13c29e3620d7.zip
Split state into stages to handle messages
Diffstat (limited to 'assets/src/models')
-rw-r--r--assets/src/models/incoming_request.ts16
-rw-r--r--assets/src/models/own_request.ts40
2 files changed, 1 insertions, 55 deletions
diff --git a/assets/src/models/incoming_request.ts b/assets/src/models/incoming_request.ts
index 4af1e02..f784540 100644
--- a/assets/src/models/incoming_request.ts
+++ b/assets/src/models/incoming_request.ts
@@ -1,6 +1,5 @@
-import { bindTransfer, Transfer } from "../network/transfer/transfer";
+import type { Transfer } from "../network/transfer/transfer";
 import { Writable, writable } from "svelte/store";
-import { createOfferTransfer } from "../network/transfer/share_transfer";
 
 // Represents the current progress of every request
 export enum IncomingRequestState {
@@ -58,16 +57,3 @@ export function newIncomingRequest(
         state: writable(IncomingRequestState.WAITING),
     };
 }
-
-// Starts the transfer of data from the sharer to the requestor
-export function acceptIncomingRequest(request: IncomingRequest) {
-    request.state.set(IncomingRequestState.IN_FLIGHT);
-
-    bindTransfer(request, createOfferTransfer(request.info.token), () =>
-        request.state.set(IncomingRequestState.DONE)
-    );
-}
-
-export function declineIncomingRequest(request: IncomingRequest) {
-    // TODO
-}
diff --git a/assets/src/models/own_request.ts b/assets/src/models/own_request.ts
deleted file mode 100644
index 2ad29af..0000000
--- a/assets/src/models/own_request.ts
+++ /dev/null
@@ -1,40 +0,0 @@
-import { bindTransfer, Transfer } from "../network/transfer/transfer";
-import { writable, Writable } from "svelte/store";
-import { createAnswerTransfer } from "../network/transfer/request_transfer";
-
-// Represents the current progress of the request
-export enum OwnRequestState {
-    PENDING,
-    ACKNOWLEDGED,
-
-    IN_FLIGHT,
-    DONE,
-
-    DECLINED,
-    SHARE_CANCELLED,
-    NO_SUCH_SHARE,
-}
-
-export type OwnRequest = {
-    // Transfer is null while request isn't IN_FLIGHT
-    transfer: Transfer | null;
-    state: Writable<OwnRequestState>;
-};
-
-export function initializeRequest(): OwnRequest {
-    return {
-        transfer: null,
-        state: writable(OwnRequestState.PENDING),
-    };
-}
-
-export function requestAccepted(
-    request: OwnRequest,
-    description: RTCSessionDescriptionInit
-) {
-    request.state.set(OwnRequestState.IN_FLIGHT);
-
-    bindTransfer(request, createAnswerTransfer(description), () =>
-        request.state.set(OwnRequestState.DONE)
-    );
-}