From 8f0db704875538cd80bc739bb109f480b5f12d04 Mon Sep 17 00:00:00 2001 From: watsonb8 Date: Mon, 18 Sep 2023 21:01:38 -0500 Subject: [PATCH] Updating packages --- client.go | 10 +++++----- examples/groupme.go | 6 +++--- extensions/debug.go | 3 +-- extensions/getstream.go | 2 +- go.mod | 2 +- internal/dispatcher/dispatcher.go | 8 ++++---- internal/store/subscription.go | 2 +- subscription/subscription.go | 2 +- transport/transport.go | 2 +- transport/websocket/websocket.go | 8 ++++---- 10 files changed, 22 insertions(+), 23 deletions(-) diff --git a/client.go b/client.go index ef35bc2..915e885 100644 --- a/client.go +++ b/client.go @@ -1,11 +1,11 @@ package fayec import ( - "github.com/thesyncim/fayec/internal/dispatcher" - "github.com/thesyncim/fayec/message" - "github.com/thesyncim/fayec/subscription" - "github.com/thesyncim/fayec/transport" - _ "github.com/thesyncim/fayec/transport/websocket" + "gitea.watsonlabs.net/watsonb8/fayec/internal/dispatcher" + "gitea.watsonlabs.net/watsonb8/fayec/message" + "gitea.watsonlabs.net/watsonb8/fayec/subscription" + "gitea.watsonlabs.net/watsonb8/fayec/transport" + _ "gitea.watsonlabs.net/watsonb8/fayec/transport/websocket" ) type options struct { diff --git a/examples/groupme.go b/examples/groupme.go index dca441f..1e8ad41 100644 --- a/examples/groupme.go +++ b/examples/groupme.go @@ -2,9 +2,9 @@ package main import ( "fmt" - "github.com/thesyncim/fayec" - "github.com/thesyncim/fayec/message" - "github.com/thesyncim/fayec/subscription" + "gitea.watsonlabs.net/watsonb8/fayec" + "gitea.watsonlabs.net/watsonb8/fayec/message" + "gitea.watsonlabs.net/watsonb8/fayec/subscription" "time" ) diff --git a/extensions/debug.go b/extensions/debug.go index 7dde847..7e4dc1e 100644 --- a/extensions/debug.go +++ b/extensions/debug.go @@ -2,7 +2,7 @@ package extensions import ( "encoding/json" - "github.com/thesyncim/faye/message" + "gitea.watsonlabs.net/watsonb8/fayec/message" "io" "log" ) @@ -12,7 +12,6 @@ func debugJson(v interface{}) string { return string(b) } -// type DebugExtension struct { in *log.Logger out *log.Logger diff --git a/extensions/getstream.go b/extensions/getstream.go index 84f435e..bb72590 100644 --- a/extensions/getstream.go +++ b/extensions/getstream.go @@ -1,7 +1,7 @@ package extensions import ( - "github.com/thesyncim/faye/message" + "gitea.watsonlabs.net/watsonb8/fayec/message" ) type GetStream struct { diff --git a/go.mod b/go.mod index 51f4e93..5ed66d3 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/thesyncim/fayec +module gitea.watsonlabs.net/watsonb8/fayec go 1.21.0 diff --git a/internal/dispatcher/dispatcher.go b/internal/dispatcher/dispatcher.go index dabcdc7..a385f37 100644 --- a/internal/dispatcher/dispatcher.go +++ b/internal/dispatcher/dispatcher.go @@ -2,10 +2,10 @@ package dispatcher import ( "fmt" - "github.com/thesyncim/fayec/internal/store" - "github.com/thesyncim/fayec/message" - "github.com/thesyncim/fayec/subscription" - "github.com/thesyncim/fayec/transport" + "gitea.watsonlabs.net/watsonb8/fayec/internal/store" + "gitea.watsonlabs.net/watsonb8/fayec/message" + "gitea.watsonlabs.net/watsonb8/fayec/subscription" + "gitea.watsonlabs.net/watsonb8/fayec/transport" "log" "strconv" "sync" diff --git a/internal/store/subscription.go b/internal/store/subscription.go index 1374423..2176300 100644 --- a/internal/store/subscription.go +++ b/internal/store/subscription.go @@ -1,7 +1,7 @@ package store import ( - "github.com/thesyncim/fayec/subscription" + "gitea.watsonlabs.net/watsonb8/fayec/subscription" "sync" ) diff --git a/subscription/subscription.go b/subscription/subscription.go index 960099e..314291c 100644 --- a/subscription/subscription.go +++ b/subscription/subscription.go @@ -2,7 +2,7 @@ package subscription import ( "errors" - "github.com/thesyncim/fayec/message" + "gitea.watsonlabs.net/watsonb8/fayec/message" "regexp" ) diff --git a/transport/transport.go b/transport/transport.go index 4a52b52..ff7c5dd 100644 --- a/transport/transport.go +++ b/transport/transport.go @@ -2,7 +2,7 @@ package transport import ( "crypto/tls" - "github.com/thesyncim/fayec/message" + "gitea.watsonlabs.net/watsonb8/fayec/message" "net/http" "time" ) diff --git a/transport/websocket/websocket.go b/transport/websocket/websocket.go index ef5ccb0..071eec7 100644 --- a/transport/websocket/websocket.go +++ b/transport/websocket/websocket.go @@ -3,9 +3,9 @@ package websocket import ( "crypto/tls" "encoding/json" + "gitea.watsonlabs.net/watsonb8/fayec/message" + "gitea.watsonlabs.net/watsonb8/fayec/transport" "github.com/gorilla/websocket" - "github.com/thesyncim/fayec/message" - "github.com/thesyncim/fayec/transport" "log" "net" "sync" @@ -134,8 +134,8 @@ func (w *Websocket) Handshake(msg *message.Message) (resp *message.Message, err return resp, nil } -//Init is called after a client has discovered the server’s capabilities with a handshake exchange, -//a connection is established by sending a message to the /meta/connect channel +// Init is called after a client has discovered the server’s capabilities with a handshake exchange, +// a connection is established by sending a message to the /meta/connect channel func (w *Websocket) Connect(msg *message.Message) error { go func() { log.Fatal(w.readWorker())