Merge pull request #1880 from dedis/work-be1-etienne-stuart-push-rumor

[BE1] Push Rumor

be1-go/cli/cli.go

@@ -100,6 +100,11 @@ func (s *ServerConfig) newHub(l *zerolog.Logger) (hub.Hub, error) {
 		}
 	}
 
+	err = db.StoreFirstRumor()
+	if err != nil {
+		return nil, err
+	}
+
 	utils.InitUtils(l, schemaValidator)
 
 	state.InitState(l)

be1-go/cli/pop_test.go

@@ -1,5 +1,6 @@
 package main
 
+//
 //import (
 //	"context"
 //	"os"

be1-go/cli/test_config_files/valid_config_watcher.json

@@ -1 +1 @@
-{"public-key":"","client-address":"ws://localhost:9000/client","server-address":"ws://localhost:9001/server","server-public-address":"localhost","server-listen-address":"localhost","auth-server-address":"localhost","client-port":9000,"server-port":9001,"auth-port":9100,"other-servers":[]}
+{"public-key":"","client-address":"ws://localhost:9000/client","server-address":"ws://localhost:9001/server","server-public-address":"localhost","server-listen-address":"localhost","auth-server-address":"localhost","client-port":9000,"server-port":9001,"auth-port":9100,"other-servers":[],"database-path":""}

be1-go/configServer3.json

@@ -0,0 +1,15 @@
+{
+    "public-key"                           : "",
+    "server-address"                       : "ws://127.0.0.1:9005/server",
+    "client-address"                       : "ws://127.0.0.1:9004/client",
+    "server-public-address"                : "localhost",
+    "server-listen-address"                : "localhost",
+    "auth-server-address"                  : "localhost",
+    "client-port"                          : 9004,
+    "server-port"                          : 9005,
+    "auth-port"                            : 9201,
+    "other-servers": [
+        "localhost:9003"
+    ],
+    "database-path"                        : "./database-c/sqlite.db"
+}

be1-go/internal/popserver/database/database.go

@@ -30,6 +30,10 @@ func getInstance() (repository.Repository, *answer.Error) {
 	return instance, nil
 }
 
+func GetRumorSenderRepositoryInstance() (repository.RumorSenderRepository, *answer.Error) {
+	return getInstance()
+}
+
 func GetQueryRepositoryInstance() (repository.QueryRepository, *answer.Error) {
 	return getInstance()
 }

be1-go/internal/popserver/database/repository/repository.go

@@ -4,6 +4,7 @@ import (
 	"go.dedis.ch/kyber/v3"
 	"popstellar/internal/popserver/types"
 	"popstellar/message/messagedata"
+	"popstellar/message/query/method"
 	"popstellar/message/query/method/message"
 )
 
@@ -17,6 +18,7 @@ type Repository interface {
 	ChirpRepository
 	CoinRepository
 	ReactionRepository
+	RumorSenderRepository
 	FederationRepository
 
 	// StoreServerKeys stores the keys of the server
@@ -35,6 +37,14 @@ type Repository interface {
 	GetMessageByID(ID string) (message.Message, error)
 }
 
+type RumorSenderRepository interface {
+	// AddMessageToMyRumor adds the message to the last rumor of the server and returns the current number of message inside the last rumor
+	AddMessageToMyRumor(messageID string) (int, error)
+
+	// GetAndIncrementMyRumor return false if the last rumor is empty otherwise returns the new rumor to send and create the next rumor
+	GetAndIncrementMyRumor() (bool, method.Rumor, error)
+}
+
 // ======================= Query ==========================
 
 type QueryRepository interface {
@@ -47,6 +57,15 @@ type QueryRepository interface {
 	GetAllMessagesFromChannel(channelID string) ([]message.Message, error)
 
 	GetParamsHeartbeat() (map[string][]string, error)
+
+	// CheckRumor returns true if the rumor already exists
+	CheckRumor(senderID string, rumorID int) (bool, error)
+
+	// StoreRumor stores the new rumor with its processed and unprocessed messages
+	StoreRumor(rumorID int, sender string, unprocessed map[string][]message.Message, processed []string) error
+
+	// GetUnprocessedMessagesByChannel returns all the unprocessed messages by channel
+	GetUnprocessedMessagesByChannel() (map[string][]message.Message, error)
 }
 
 // ======================= Answer ==========================