From ffd039f5fd9ef55bb85b45698e676eb424a954a9 Mon Sep 17 00:00:00 2001 From: Marcos Candeia Date: Mon, 30 Sep 2024 09:24:58 -0300 Subject: [PATCH] Refactoring channel folder Signed-off-by: Marcos Candeia --- src/actors/proxy.ts | 6 +++--- src/actors/runtime.test.ts | 2 +- src/actors/runtime.ts | 2 +- src/actors/{ => util}/channels/channel.ts | 0 src/actors/{ => util}/channels/serializers.ts | 0 5 files changed, 5 insertions(+), 5 deletions(-) rename src/actors/{ => util}/channels/channel.ts (100%) rename src/actors/{ => util}/channels/serializers.ts (100%) diff --git a/src/actors/proxy.ts b/src/actors/proxy.ts index ec6bc53..b729e1b 100644 --- a/src/actors/proxy.ts +++ b/src/actors/proxy.ts @@ -1,10 +1,10 @@ +import type { Actor, ActorConstructor } from "./runtime.ts"; +import { EVENT_STREAM_RESPONSE_HEADER, readFromStream } from "./stream.ts"; import { type ChannelUpgrader, type DuplexChannel, makeWebSocket, -} from "./channels/channel.ts"; -import type { Actor, ActorConstructor } from "./runtime.ts"; -import { EVENT_STREAM_RESPONSE_HEADER, readFromStream } from "./stream.ts"; +} from "./util/channels/channel.ts"; export const ACTOR_ID_HEADER_NAME = "x-deno-isolate-instance-id"; export const ACTOR_ID_QS_NAME = "x-deno-isolate-instance-id"; diff --git a/src/actors/runtime.test.ts b/src/actors/runtime.test.ts index b74f4e7..5513137 100644 --- a/src/actors/runtime.test.ts +++ b/src/actors/runtime.test.ts @@ -1,8 +1,8 @@ import { assertEquals, assertFalse } from "@std/assert"; -import type { ChannelUpgrader } from "./channels/channel.ts"; import { actors } from "./proxy.ts"; import { ActorRuntime } from "./runtime.ts"; import type { ActorState } from "./state.ts"; +import type { ChannelUpgrader } from "./util/channels/channel.ts"; import { WatchTarget } from "./util/watch.ts"; class Counter { diff --git a/src/actors/runtime.ts b/src/actors/runtime.ts index c9690ef..283c499 100644 --- a/src/actors/runtime.ts +++ b/src/actors/runtime.ts @@ -1,5 +1,5 @@ import { type ServerSentEventMessage, ServerSentEventStream } from "@std/http"; -import { isUpgrade, makeWebSocket } from "./channels/channel.ts"; +import { isUpgrade, makeWebSocket } from "./util/channels/channel.ts"; import { ACTOR_ID_HEADER_NAME, ACTOR_ID_QS_NAME } from "./proxy.ts"; import { ActorState } from "./state.ts"; import { DenoKvActorStorage } from "./storage/denoKv.ts"; diff --git a/src/actors/channels/channel.ts b/src/actors/util/channels/channel.ts similarity index 100% rename from src/actors/channels/channel.ts rename to src/actors/util/channels/channel.ts diff --git a/src/actors/channels/serializers.ts b/src/actors/util/channels/serializers.ts similarity index 100% rename from src/actors/channels/serializers.ts rename to src/actors/util/channels/serializers.ts