aboutsummaryrefslogtreecommitdiff
path: root/build
diff options
context:
space:
mode:
authorDevon Hudson <devonhudson@librem.one>2023-01-31 16:27:51 -0700
committerDevon Hudson <devonhudson@librem.one>2023-02-01 13:41:37 -0700
commitd4f64f91ca5afc16bfd55f64b59310f13473f016 (patch)
treed68c6f9b9d4e061562ab21b06f5b59df8a21de8f /build
parent2f8377e94b5b32f4957c1f6c64acdd8bd2880e23 (diff)
Refactor pinecone demo to remove duplicate key setup
Diffstat (limited to 'build')
-rw-r--r--build/gobind-pinecone/monolith.go42
1 files changed, 3 insertions, 39 deletions
diff --git a/build/gobind-pinecone/monolith.go b/build/gobind-pinecone/monolith.go
index 848ac79f..dd483873 100644
--- a/build/gobind-pinecone/monolith.go
+++ b/build/gobind-pinecone/monolith.go
@@ -23,7 +23,6 @@ import (
"fmt"
"net"
"net/http"
- "os"
"path/filepath"
"strings"
"time"
@@ -33,6 +32,7 @@ import (
"github.com/matrix-org/dendrite/clientapi/userutil"
"github.com/matrix-org/dendrite/cmd/dendrite-demo-pinecone/conduit"
"github.com/matrix-org/dendrite/cmd/dendrite-demo-pinecone/conn"
+ "github.com/matrix-org/dendrite/cmd/dendrite-demo-pinecone/keys"
"github.com/matrix-org/dendrite/cmd/dendrite-demo-pinecone/relay"
"github.com/matrix-org/dendrite/cmd/dendrite-demo-pinecone/rooms"
"github.com/matrix-org/dendrite/cmd/dendrite-demo-pinecone/users"
@@ -49,7 +49,6 @@ import (
"github.com/matrix-org/dendrite/setup/base"
"github.com/matrix-org/dendrite/setup/config"
"github.com/matrix-org/dendrite/setup/jetstream"
- "github.com/matrix-org/dendrite/test"
"github.com/matrix-org/dendrite/userapi"
userapiAPI "github.com/matrix-org/dendrite/userapi/api"
"github.com/matrix-org/gomatrixserverlib"
@@ -351,45 +350,10 @@ func (m *DendriteMonolith) RegisterDevice(localpart, deviceID string) (string, e
return loginRes.Device.AccessToken, nil
}
-// nolint:gocyclo
func (m *DendriteMonolith) Start() {
- var sk ed25519.PrivateKey
- var pk ed25519.PublicKey
-
keyfile := filepath.Join(m.StorageDirectory, "p2p.pem")
- if _, err := os.Stat(keyfile); os.IsNotExist(err) {
- oldkeyfile := filepath.Join(m.StorageDirectory, "p2p.key")
- if _, err = os.Stat(oldkeyfile); os.IsNotExist(err) {
- if err = test.NewMatrixKey(keyfile); err != nil {
- panic("failed to generate a new PEM key: " + err.Error())
- }
- if _, sk, err = config.LoadMatrixKey(keyfile, os.ReadFile); err != nil {
- panic("failed to load PEM key: " + err.Error())
- }
- if len(sk) != ed25519.PrivateKeySize {
- panic("the private key is not long enough")
- }
- } else {
- if sk, err = os.ReadFile(oldkeyfile); err != nil {
- panic("failed to read the old private key: " + err.Error())
- }
- if len(sk) != ed25519.PrivateKeySize {
- panic("the private key is not long enough")
- }
- if err = test.SaveMatrixKey(keyfile, sk); err != nil {
- panic("failed to convert the private key to PEM format: " + err.Error())
- }
- }
- } else {
- if _, sk, err = config.LoadMatrixKey(keyfile, os.ReadFile); err != nil {
- panic("failed to load PEM key: " + err.Error())
- }
- if len(sk) != ed25519.PrivateKeySize {
- panic("the private key is not long enough")
- }
- }
-
- pk = sk.Public().(ed25519.PublicKey)
+ oldKeyfile := filepath.Join(m.StorageDirectory, "p2p.key")
+ sk, pk := keys.GetOrCreateKey(keyfile, oldKeyfile)
var err error
m.listener, err = net.Listen("tcp", "localhost:65432")