kela

A new decentralized web protocol

  1. 1
  2. 2
  3. 3
  4. 4
  5. 5
  6. 6
  7. 7
  8. 8
  9. 9
  10. 10
  11. 11
  12. 12
  13. 13
  14. 14
  15. 15
  16. 16
  17. 17
  18. 18
  19. 19
  20. 20
  21. 21
  22. 22
  23. 23
  24. 24
  25. 25
  26. 26
  27. 27
  28. 28
  29. 29
  30. 30
  31. 31
  32. 32
  33. 33
  34. 34
  35. 35
  36. 36
  37. 37
  38. 38
  39. 39
  40. 40
  41. 41
  42. 42
  43. 43
  44. 44
  45. 45
  46. 46
  47. 47
  48. 48
  49. 49
package main

import (
	"crypto/ed25519"
	"crypto/sha256"
	"encoding/base64"
	"flag"
	"log"
	"net/http"
	"sync"
)

type user struct {
	pubkey []byte
	servers []string
}

var mu sync.Mutex
var me string
var myHash string
var myPos int
var hashToDomain map[string]string
var peerHashes []string
var kvstore map[string][]byte

func main() {
	bindAddr := flag.String("b", ":4200", "bind address")
	publicURL := flag.String("u", "http://localhost:4200", "public URL")
	peer := flag.String("i", "", "initial peer")
	flag.Parse()
	log.Printf("Starting %s %s %s", *bindAddr, *publicURL, *peer)

	// Record myself
	me = *publicURL
	myHash = sha256sum(me)
	myPos = 0
	peerHashes = append(peerHashes, sha256sum(me))
	hashToDomain = map[string]string{peerHashes[0]: me}

	if *peer != "" {
		go addPeer(*peer)
	}

	http.HandleFunc("/peer", peerHandler)
	http.HandleFunc("/dht", dhtHandler)
	http.HandleFunc("/storage", storageHandler)
	http.HandleFunc("/message", messageHandler)
	log.Fatal(http.ListenAndServe(*bindAddr, nil))
}