mirror of
https://github.com/balzack/databag.git
synced 2025-02-12 11:39:17 +00:00
101 lines
2.6 KiB
Go
101 lines
2.6 KiB
Go
package databag
|
|
|
|
import (
|
|
"testing"
|
|
"encoding/json"
|
|
"github.com/gorilla/websocket"
|
|
"github.com/gorilla/mux"
|
|
"github.com/stretchr/testify/assert"
|
|
)
|
|
|
|
func TestConnectContact(t *testing.T) {
|
|
var card Card
|
|
var revision Revision
|
|
var msg DataMessage
|
|
var vars map[string]string
|
|
var cardRevision int64
|
|
|
|
// create some contacts for this test
|
|
access := AddTestContacts(t, "connect", 2)
|
|
|
|
// get A identity message
|
|
r, w, _ := NewRequest("GET", "/profile/message", nil)
|
|
SetBearerAuth(r, access[0])
|
|
GetProfileMessage(w, r)
|
|
assert.NoError(t, ReadResponse(w, &msg))
|
|
|
|
// app connects websocket
|
|
ws := getTestWebsocket()
|
|
announce := Announce{ AppToken: access[1] }
|
|
data, _ := json.Marshal(&announce)
|
|
ws.WriteMessage(websocket.TextMessage, data)
|
|
_, data, _ = ws.ReadMessage()
|
|
assert.NoError(t, json.Unmarshal(data, &revision))
|
|
cardRevision = revision.Card
|
|
|
|
// add A card in B
|
|
r, w, _ = NewRequest("POST", "/contact/cards", &msg)
|
|
SetBearerAuth(r, access[1])
|
|
AddCard(w, r)
|
|
assert.NoError(t, ReadResponse(w, &card))
|
|
|
|
// profile revision incremented
|
|
_, data, _ = ws.ReadMessage()
|
|
assert.NoError(t, json.Unmarshal(data, &revision))
|
|
assert.NotEqual(t, cardRevision, revision.Card)
|
|
cardRevision = revision.Card
|
|
|
|
// update A status to connecting
|
|
r, w, _ = NewRequest("PUT", "/contact/cards/{cardId}/status", APP_CARDCONNECTING)
|
|
vars = map[string]string{ "cardId": card.CardId }
|
|
r = mux.SetURLVars(r, vars)
|
|
SetBearerAuth(r, access[1])
|
|
SetCardStatus(w, r)
|
|
assert.NoError(t, ReadResponse(w, &card))
|
|
|
|
// profile revision incremented
|
|
_, data, _ = ws.ReadMessage()
|
|
assert.NoError(t, json.Unmarshal(data, &revision))
|
|
assert.NotEqual(t, cardRevision, revision.Card)
|
|
cardRevision = revision.Card
|
|
|
|
// get open message to A
|
|
r, w, _ = NewRequest("GET", "/contact/cards/{cardId}/openMessage", nil)
|
|
vars = map[string]string{ "cardId": card.CardId }
|
|
r = mux.SetURLVars(r, vars)
|
|
SetBearerAuth(r, access[1])
|
|
GetOpenMessage(w, r)
|
|
assert.NoError(t, ReadResponse(w, &msg))
|
|
|
|
// set open message in A
|
|
r, w, _ = NewRequest("PUT", "/contact/openMessage", msg)
|
|
SetOpenMessage(w, r)
|
|
var contactStatus ContactStatus
|
|
assert.NoError(t, ReadResponse(w, &contactStatus))
|
|
|
|
// get view of cards in A
|
|
r, w, _ = NewRequest("GET", "/contact/card/view", nil)
|
|
SetBearerAuth(r, access[0])
|
|
GetCardView(w, r)
|
|
var views []CardView
|
|
assert.NoError(t, ReadResponse(w, &views))
|
|
|
|
PrintMsg(views);
|
|
|
|
|
|
// get new card
|
|
|
|
// set status of pending to connecting
|
|
|
|
// create open message
|
|
|
|
// deliver open message
|
|
|
|
// receive websocket message
|
|
|
|
// update status to connected
|
|
|
|
|
|
}
|
|
|