mirror of
https://github.com/acid-info/Kurate.git
synced 2025-01-12 08:54:08 +00:00
refactor: remove in-memory adapter (#382)
This commit is contained in:
Vojtech Simetka
GitHub
parent
b0a2fac43d
commit
7a0014c8aa
@ -1,548 +0,0 @@
|
||||
import { connectWallet } from '$lib/services'
|
||||
import { chats, type Chat } from '$lib/stores/chat'
|
||||
import { personas, type DraftPersona, type Persona } from '$lib/stores/persona'
|
||||
import { profile } from '$lib/stores/profile'
|
||||
import { getFromLocalStorage, saveToLocalStorage, sleep } from '$lib/utils'
|
||||
import type { Signer } from 'ethers'
|
||||
import { create } from 'ipfs-http-client'
|
||||
import {
|
||||
CREATE_PERSONA_GO_PRICE,
|
||||
DEFAULT_GO_AMOUNT,
|
||||
NEW_POST_GO_PRICE,
|
||||
NEW_POST_REP_LOSS,
|
||||
NEW_POST_REP_PRICE,
|
||||
NEW_POST_REP_WIN,
|
||||
VOTE_GO_PRICE,
|
||||
VOTE_REP_WIN,
|
||||
} from '$lib/constants'
|
||||
import { tokens } from '$lib/stores/tokens'
|
||||
import { posts, type Post } from '$lib/stores/post'
|
||||
import { transaction, type TransactionRecord } from '$lib/stores/transaction'
|
||||
|
||||
import type { Adapter } from '..'
|
||||
import {
|
||||
executeWithChance,
|
||||
randomId,
|
||||
randomIntegerBetween,
|
||||
randomPersona,
|
||||
randomPost,
|
||||
randomText,
|
||||
} from './utils'
|
||||
import { get } from 'svelte/store'
|
||||
|
||||
// FIXME: no idea where whe should put these so that they don't leak. I can limit to some specific origin I guess
|
||||
const IPFS_AUTH =
|
||||
'Basic Mk5Nbk1vZUNSTWMyOTlCQjYzWm9QZzlQYTU3OjAwZTk2MmJjZTBkZmQxZWQxNGNhNmY1M2JiYjYxMTli'
|
||||
const IPFS_GATEWAY = 'https://kurate.infura-ipfs.io/ipfs'
|
||||
|
||||
function addRandomPost(groupId: string, pending: boolean) {
|
||||
const post = randomPost()
|
||||
if (pending) posts.addPending(post, groupId)
|
||||
else posts.addApproved(post, groupId)
|
||||
}
|
||||
|
||||
function addRandomPersona() {
|
||||
// FIXME: it can happen that this ID already exists
|
||||
const groupId = randomId()
|
||||
personas.update((state) => {
|
||||
const persona = randomPersona(groupId)
|
||||
state.all.set(groupId, persona)
|
||||
|
||||
// The persona should have 5-15 approved posts
|
||||
for (let i = 0; i < randomIntegerBetween(5, 15); i++) {
|
||||
addRandomPost(groupId, false)
|
||||
}
|
||||
|
||||
// The persona should have 0-20 pending posts
|
||||
for (let i = 0; i < randomIntegerBetween(0, 20); i++) {
|
||||
addRandomPost(groupId, true)
|
||||
}
|
||||
|
||||
return { ...state }
|
||||
})
|
||||
}
|
||||
|
||||
function addRandomThings() {
|
||||
// 1% chance to add new persona every second
|
||||
if (executeWithChance(0.01)) addRandomPersona()
|
||||
}
|
||||
|
||||
function startAddition(): () => unknown {
|
||||
const interval = setInterval(addRandomThings, 1000)
|
||||
|
||||
return () => {
|
||||
clearInterval(interval)
|
||||
}
|
||||
}
|
||||
|
||||
export async function startNewEpoch() {
|
||||
const newTransactions: TransactionRecord[] = []
|
||||
const totalRepChange = await new Promise<number>((resolve) => {
|
||||
posts.update((pState) => {
|
||||
const { data } = pState
|
||||
let repChange = 0
|
||||
|
||||
data.forEach((values, key) => {
|
||||
const val = values
|
||||
val.pending = []
|
||||
values.pending.forEach((post) => {
|
||||
const included = executeWithChance(0.5)
|
||||
if (included) {
|
||||
val.approved.push(post)
|
||||
}
|
||||
|
||||
if (post.myPost) {
|
||||
if (included) {
|
||||
repChange += NEW_POST_REP_WIN
|
||||
newTransactions.push({
|
||||
timestamp: Date.now(),
|
||||
goChange: 0,
|
||||
repChange: NEW_POST_REP_WIN,
|
||||
personaId: key,
|
||||
type: 'post_included',
|
||||
})
|
||||
} else {
|
||||
repChange -= NEW_POST_REP_LOSS
|
||||
newTransactions.push({
|
||||
timestamp: Date.now(),
|
||||
goChange: 0,
|
||||
repChange: NEW_POST_REP_WIN,
|
||||
personaId: key,
|
||||
type: 'post_rejected',
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
if (post.yourVote) {
|
||||
if ((included && post.yourVote === '+') || (!included && post.yourVote === '-')) {
|
||||
repChange += VOTE_REP_WIN
|
||||
newTransactions.push({
|
||||
timestamp: Date.now(),
|
||||
goChange: 0,
|
||||
repChange: VOTE_REP_WIN,
|
||||
personaId: key,
|
||||
type: 'vote_win',
|
||||
})
|
||||
}
|
||||
}
|
||||
})
|
||||
data.set(key, val)
|
||||
})
|
||||
|
||||
resolve(repChange)
|
||||
return { data }
|
||||
})
|
||||
})
|
||||
|
||||
tokens.update((tState) => {
|
||||
let { repStaked, repTotal, go } = tState
|
||||
|
||||
go = DEFAULT_GO_AMOUNT
|
||||
repTotal = Math.max(repTotal + totalRepChange, 0)
|
||||
repStaked = 0
|
||||
|
||||
return { ...tState, repStaked, repTotal, go }
|
||||
})
|
||||
|
||||
transaction.update((tState) => {
|
||||
return { ...tState, transaction: [...tState.transactions, newTransactions] }
|
||||
})
|
||||
}
|
||||
|
||||
function startEpochTimer(): () => unknown {
|
||||
const interval = setInterval(() => {
|
||||
tokens.update(({ timeToEpoch, epochDuration, ...rest }) => {
|
||||
const newTimeToEpoch = epochDuration - (Date.now() % epochDuration)
|
||||
|
||||
if (timeToEpoch < newTimeToEpoch) {
|
||||
startNewEpoch()
|
||||
}
|
||||
|
||||
return { ...rest, epochDuration, timeToEpoch: newTimeToEpoch }
|
||||
})
|
||||
}, 1000)
|
||||
|
||||
return () => {
|
||||
clearInterval(interval)
|
||||
}
|
||||
}
|
||||
|
||||
export class InMemoryAndIPFS implements Adapter {
|
||||
private ipfs = create({
|
||||
host: 'ipfs.infura.io',
|
||||
port: 5001,
|
||||
protocol: 'https',
|
||||
headers: {
|
||||
authorization: IPFS_AUTH,
|
||||
},
|
||||
})
|
||||
private subscriptions: Array<() => unknown> = []
|
||||
|
||||
async start() {
|
||||
const storedPersonas = new Map<string, Persona>(getFromLocalStorage('personas', []))
|
||||
const draftPersonas = getFromLocalStorage('drafts', [])
|
||||
const storedChats = new Map<string, Chat>(getFromLocalStorage('chats', []))
|
||||
const storedPosts = new Map<string, { approved: Post[]; pending: Post[]; loading: boolean }>(
|
||||
getFromLocalStorage('posts', []),
|
||||
)
|
||||
const storedTransactions = getFromLocalStorage<TransactionRecord[]>('transactions', [])
|
||||
const epochDuration = 5 * 60 * 1000
|
||||
const storedTokens = getFromLocalStorage('tokens', {
|
||||
go: DEFAULT_GO_AMOUNT,
|
||||
repTotal: 55,
|
||||
repStaked: 5,
|
||||
loading: false,
|
||||
goHistoricalValues: [],
|
||||
repStakedHistoricalValues: [],
|
||||
repTotalHistoricalValues: [],
|
||||
epochDuration,
|
||||
timeToEpoch: epochDuration - (Date.now() % epochDuration),
|
||||
})
|
||||
transaction.set({ transactions: storedTransactions })
|
||||
|
||||
tokens.set(storedTokens)
|
||||
|
||||
this.subscriptions.push(
|
||||
transaction.subscribe(({ transactions }) => {
|
||||
saveToLocalStorage('transactions', transactions)
|
||||
}),
|
||||
)
|
||||
|
||||
this.subscriptions.push(startEpochTimer())
|
||||
|
||||
// It takes 1 second to load all the data :)
|
||||
await sleep(1000)
|
||||
|
||||
// There is no persona so we create one in 1 second :)
|
||||
if (storedPersonas.size === 0) setTimeout(addRandomPersona, 1000)
|
||||
|
||||
personas.update((state) => {
|
||||
return {
|
||||
...state,
|
||||
all: storedPersonas,
|
||||
draft: draftPersonas,
|
||||
loading: false,
|
||||
}
|
||||
})
|
||||
|
||||
chats.update((state) => {
|
||||
return {
|
||||
...state,
|
||||
chats: storedChats,
|
||||
loading: false,
|
||||
}
|
||||
})
|
||||
|
||||
posts.set({ data: storedPosts })
|
||||
|
||||
this.subscriptions.push(
|
||||
personas.subscribe(({ all }) => {
|
||||
saveToLocalStorage('personas', Array.from(all.entries()))
|
||||
}),
|
||||
)
|
||||
this.subscriptions.push(
|
||||
chats.subscribe(({ chats }) => {
|
||||
saveToLocalStorage('chats', Array.from(chats.entries()))
|
||||
}),
|
||||
)
|
||||
this.subscriptions.push(
|
||||
posts.subscribe(({ data }) => {
|
||||
saveToLocalStorage('posts', Array.from(data.entries()))
|
||||
}),
|
||||
)
|
||||
this.subscriptions.push(startAddition())
|
||||
|
||||
chats.update((state) => {
|
||||
return { ...state, loading: false }
|
||||
})
|
||||
}
|
||||
stop() {
|
||||
this.subscriptions.forEach((s) => s())
|
||||
}
|
||||
addPersonaToFavorite(groupId: string): Promise<void> {
|
||||
return new Promise((resolve) => {
|
||||
personas.update(({ favorite, ...store }) => {
|
||||
const favoriteNew: string[] = [...favorite, groupId]
|
||||
|
||||
saveToLocalStorage('favorite', favoriteNew)
|
||||
|
||||
resolve()
|
||||
return { ...store, favorite: favoriteNew }
|
||||
})
|
||||
})
|
||||
}
|
||||
removePersonaFromFavorite(groupId: string): Promise<void> {
|
||||
return new Promise((resolve) => {
|
||||
personas.update(({ favorite, ...store }) => {
|
||||
const favoriteNew: string[] = favorite.filter((s) => s !== groupId)
|
||||
|
||||
saveToLocalStorage('favorite', favoriteNew)
|
||||
|
||||
resolve()
|
||||
return { ...store, favorite: favoriteNew }
|
||||
})
|
||||
})
|
||||
}
|
||||
addPersonaDraft(draftPersona: DraftPersona): Promise<number> {
|
||||
return new Promise((resolve) =>
|
||||
personas.update(({ draft, ...state }) => {
|
||||
const newDraft = [...draft, draftPersona]
|
||||
|
||||
saveToLocalStorage('drafts', newDraft)
|
||||
|
||||
resolve(newDraft.length - 1)
|
||||
|
||||
return { ...state, draft: newDraft }
|
||||
}),
|
||||
)
|
||||
}
|
||||
updatePersonaDraft(index: number, draftPersona: DraftPersona): Promise<void> {
|
||||
return new Promise((resolve) =>
|
||||
personas.update(({ draft, ...state }) => {
|
||||
draft[index] = draftPersona
|
||||
|
||||
saveToLocalStorage('drafts', draft)
|
||||
|
||||
resolve()
|
||||
|
||||
return { ...state, draft }
|
||||
}),
|
||||
)
|
||||
}
|
||||
|
||||
deleteDraftPersona(index: number): Promise<void> {
|
||||
return new Promise((resolve) =>
|
||||
personas.update(({ draft, ...state }) => {
|
||||
const newDraft = draft.filter((_, i) => i !== index)
|
||||
|
||||
saveToLocalStorage('drafts', newDraft)
|
||||
|
||||
resolve()
|
||||
|
||||
return { ...state, draft: newDraft }
|
||||
}),
|
||||
)
|
||||
}
|
||||
|
||||
async publishPersona(draftPersona: DraftPersona, signer: Signer): Promise<string> {
|
||||
await signer.signMessage('This "transaction" publishes persona')
|
||||
|
||||
function getRandomNonExistingId(): Promise<string> {
|
||||
let groupId = randomId()
|
||||
return new Promise((resolve) => {
|
||||
personas.subscribe((s) => {
|
||||
while (s.all.has(groupId)) {
|
||||
groupId = randomId()
|
||||
}
|
||||
resolve(groupId)
|
||||
})
|
||||
})
|
||||
}
|
||||
|
||||
const groupId = await getRandomNonExistingId()
|
||||
|
||||
personas.update((state) => {
|
||||
state.all.set(groupId, {
|
||||
...draftPersona,
|
||||
postsCount: 5,
|
||||
participantsCount: 1,
|
||||
personaId: groupId,
|
||||
})
|
||||
|
||||
return { ...state }
|
||||
})
|
||||
|
||||
draftPersona.posts.forEach((p) => posts.addApproved({ ...p, postId: randomId() }, groupId))
|
||||
|
||||
personas.update(({ draft, ...state }) => {
|
||||
const newDraft = draft.filter((d) => d !== draftPersona)
|
||||
|
||||
saveToLocalStorage('drafts', newDraft)
|
||||
|
||||
return { ...state, draft: newDraft }
|
||||
})
|
||||
|
||||
tokens.update(({ go, ...state }) => {
|
||||
return { ...state, go: go - CREATE_PERSONA_GO_PRICE }
|
||||
})
|
||||
|
||||
transaction.update(({ transactions }) => {
|
||||
transactions.push({
|
||||
timestamp: Date.now(),
|
||||
goChange: -CREATE_PERSONA_GO_PRICE,
|
||||
repChange: 0,
|
||||
personaId: groupId,
|
||||
type: 'publish persona',
|
||||
})
|
||||
return { transactions }
|
||||
})
|
||||
|
||||
return groupId
|
||||
}
|
||||
|
||||
async signIn(): Promise<void> {
|
||||
const signer = await connectWallet()
|
||||
const address = await signer.getAddress()
|
||||
|
||||
profile.update((state) => ({ ...state, signer, address }))
|
||||
}
|
||||
|
||||
async uploadPicture(picture: string): Promise<string> {
|
||||
const blob = await (await fetch(picture)).blob()
|
||||
const res = await this.ipfs.add(blob)
|
||||
|
||||
return res.cid.toString()
|
||||
}
|
||||
|
||||
getPicture(cid: string): string {
|
||||
if (cid.startsWith('/')) return `https://picsum.photos/seed${cid}`
|
||||
return `${IPFS_GATEWAY}/${cid}`
|
||||
}
|
||||
|
||||
async publishPost(
|
||||
groupId: string,
|
||||
text: string,
|
||||
images: string[],
|
||||
signer: Signer,
|
||||
): Promise<string> {
|
||||
await signer.signMessage('This "transaction" publishes a post to pending')
|
||||
|
||||
const post = {
|
||||
timestamp: Date.now(),
|
||||
text,
|
||||
images,
|
||||
postId: randomId(),
|
||||
}
|
||||
|
||||
tokens.update(({ go, repStaked, ...state }) => {
|
||||
return { ...state, repStaked: repStaked + NEW_POST_REP_PRICE, go: go - NEW_POST_GO_PRICE }
|
||||
})
|
||||
|
||||
posts.addPending(post, groupId)
|
||||
|
||||
transaction.update(({ transactions }) => {
|
||||
transactions.push({
|
||||
timestamp: Date.now(),
|
||||
goChange: -NEW_POST_GO_PRICE,
|
||||
repChange: -NEW_POST_REP_PRICE,
|
||||
personaId: groupId,
|
||||
type: 'publish post',
|
||||
})
|
||||
return { transactions }
|
||||
})
|
||||
|
||||
return post.postId
|
||||
}
|
||||
|
||||
async subscribePersonaPosts(groupId: string): Promise<() => unknown> {
|
||||
const interval = setInterval(() => {
|
||||
// 5% chance every second to add new pending post
|
||||
if (executeWithChance(0.05)) addRandomPost(groupId, true)
|
||||
}, 1000)
|
||||
|
||||
return () => clearInterval(interval)
|
||||
}
|
||||
|
||||
async voteOnPost(groupId: string, postId: string, vote: '+' | '-', signer: Signer) {
|
||||
await signer.signMessage(`This "transaction" votes ${vote === '+' ? 'promote' : 'demote'}`)
|
||||
|
||||
posts.update((state) => {
|
||||
const posts = state.data.get(groupId)
|
||||
if (posts) {
|
||||
const newPosts = posts.pending.filter((p) => p.postId !== postId)
|
||||
const newPost = posts.pending.find((p) => p.postId === postId)
|
||||
if (newPost) {
|
||||
newPost.yourVote = vote
|
||||
state.data.set(groupId, { ...posts, pending: [...newPosts, newPost] })
|
||||
}
|
||||
}
|
||||
|
||||
return state
|
||||
})
|
||||
|
||||
tokens.update(({ go, ...state }) => {
|
||||
return {
|
||||
...state,
|
||||
go: go - VOTE_GO_PRICE,
|
||||
}
|
||||
})
|
||||
transaction.update(({ transactions }) => {
|
||||
transactions.push({
|
||||
timestamp: Date.now(),
|
||||
goChange: -VOTE_GO_PRICE,
|
||||
repChange: 0,
|
||||
type: vote === '+' ? 'promote' : 'demote',
|
||||
personaId: groupId,
|
||||
})
|
||||
return { transactions }
|
||||
})
|
||||
}
|
||||
|
||||
startChat(chat: Chat): Promise<string> {
|
||||
return new Promise((resolve) => {
|
||||
const seed = randomId()
|
||||
chats.update((state) => {
|
||||
state.chats.set(seed, { ...chat, chatId: seed })
|
||||
resolve(seed)
|
||||
return state
|
||||
})
|
||||
})
|
||||
}
|
||||
|
||||
sendChatMessage(chatId: string, text: string): Promise<void> {
|
||||
return new Promise((resolve) => {
|
||||
chats.update((state) => {
|
||||
const chat = state.chats.get(chatId)
|
||||
const address = get(profile).address
|
||||
if (!chat || !address) throw new Error('Chat not found')
|
||||
|
||||
chat.messages.push({
|
||||
timestamp: Date.now(),
|
||||
text,
|
||||
address,
|
||||
})
|
||||
state.chats.set(chatId, chat)
|
||||
resolve()
|
||||
return { ...state }
|
||||
})
|
||||
})
|
||||
}
|
||||
|
||||
async subscribeToChat(chatId: string): Promise<() => unknown> {
|
||||
const interval = setInterval(() => {
|
||||
chats.update((state) => {
|
||||
const chat = state.chats.get(chatId)
|
||||
const address = get(profile).address
|
||||
if (!chat || !address) throw new Error('Chat not found')
|
||||
|
||||
const lastMessage = chat.messages[chat.messages.length - 1]
|
||||
// 10% chance every second to add new message and only when the last message was sent by me
|
||||
if (lastMessage.address === address && executeWithChance(0.1)) {
|
||||
const newMessage = {
|
||||
timestamp: Date.now(),
|
||||
text: randomText(randomIntegerBetween(1, 5)),
|
||||
address: randomId(),
|
||||
}
|
||||
chat.messages.push(newMessage)
|
||||
state.chats.set(chatId, chat)
|
||||
}
|
||||
return { ...state }
|
||||
})
|
||||
}, 1000)
|
||||
|
||||
return () => {
|
||||
clearInterval(interval)
|
||||
}
|
||||
}
|
||||
|
||||
async queryPersonaJoined(personId: string): Promise<boolean> {
|
||||
// FIXME: properly implement
|
||||
console.error('NOT IMPLEMENTED', 'subscribeToChat')
|
||||
return true
|
||||
}
|
||||
|
||||
async joinPersona(personId: string): Promise<void> {
|
||||
// FIXME: properly implement
|
||||
console.error('NOT IMPLEMENTED', 'subscribeToChat')
|
||||
}
|
||||
}
|
||||
File diff suppressed because one or more lines are too long
@ -1,108 +0,0 @@
|
||||
import { MAX_DIMENSIONS } from '$lib/constants'
|
||||
import type { Persona } from '$lib/stores/persona'
|
||||
import type { Post } from '$lib/stores/post'
|
||||
import type { ReputationOptions } from '$lib/types'
|
||||
import { ethers } from 'ethers'
|
||||
import lipsum from './lipsum'
|
||||
|
||||
export function randomText(sentenceCount: number): string {
|
||||
const res: string[] = []
|
||||
|
||||
for (let i = 0; i < sentenceCount; i++) {
|
||||
res.push(lipsum[Math.floor(Math.random() * lipsum.length)])
|
||||
}
|
||||
|
||||
return `${res.join('. ')}.`
|
||||
}
|
||||
|
||||
export function executeWithChance(chance: number): boolean {
|
||||
return Math.random() < chance
|
||||
}
|
||||
|
||||
export function randomIntegerBetween(min: number, max: number): number {
|
||||
return Math.floor(Math.random() * (max - min) + min)
|
||||
}
|
||||
|
||||
export function randomId(): string {
|
||||
const randomUUID = crypto.randomUUID()
|
||||
const encoder = new TextEncoder()
|
||||
return ethers.utils.sha256(encoder.encode(randomUUID))
|
||||
}
|
||||
|
||||
export function randomPost(): Post {
|
||||
const images: string[] = []
|
||||
|
||||
// Only 35% of posts should have a picture
|
||||
if (executeWithChance(0.35)) {
|
||||
// Only 40% of posts with pictures can have more than 3
|
||||
const max = executeWithChance(0.4) ? 20 : 3
|
||||
for (let i = 0; i < randomIntegerBetween(1, max); i++) {
|
||||
images.push(
|
||||
randomPicture(MAX_DIMENSIONS.POST_PICTURE.width, MAX_DIMENSIONS.POST_PICTURE.height),
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
const post: Post = {
|
||||
postId: randomId(),
|
||||
text: randomText(randomIntegerBetween(1, 15)),
|
||||
timestamp: Date.now(),
|
||||
images,
|
||||
}
|
||||
|
||||
return post
|
||||
}
|
||||
|
||||
export function randomPersona(personaId: string): Persona {
|
||||
const name = randomText(1).split(' ')[0]
|
||||
const pitch = randomText(randomIntegerBetween(1, 3))
|
||||
const description = randomText(randomIntegerBetween(5, 20))
|
||||
const cover = randomPicture(
|
||||
MAX_DIMENSIONS.PERSONA_COVER.width,
|
||||
MAX_DIMENSIONS.PERSONA_COVER.height,
|
||||
)
|
||||
const picture = randomPicture(
|
||||
MAX_DIMENSIONS.PERSONA_PICTURE.width,
|
||||
MAX_DIMENSIONS.PERSONA_PICTURE.height,
|
||||
)
|
||||
let minReputation: ReputationOptions
|
||||
switch (randomIntegerBetween(0, 10)) {
|
||||
case 0:
|
||||
minReputation = 500
|
||||
break
|
||||
case 1:
|
||||
minReputation = 250
|
||||
break
|
||||
case 2:
|
||||
case 3:
|
||||
minReputation = 100
|
||||
break
|
||||
case 4:
|
||||
case 5:
|
||||
case 6:
|
||||
minReputation = 25
|
||||
break
|
||||
default:
|
||||
minReputation = 5
|
||||
break
|
||||
}
|
||||
|
||||
const persona: Persona = {
|
||||
name,
|
||||
pitch,
|
||||
description,
|
||||
participantsCount: randomIntegerBetween(1, 1500),
|
||||
postsCount: randomIntegerBetween(1, 2000),
|
||||
cover,
|
||||
picture,
|
||||
personaId,
|
||||
minReputation,
|
||||
timestamp: Date.now(),
|
||||
}
|
||||
|
||||
return persona
|
||||
}
|
||||
|
||||
export function randomPicture(width: number, height: number): string {
|
||||
return `/${randomId()}/${width}/${height}`
|
||||
}
|
||||
@ -1,7 +1,6 @@
|
||||
import type { DraftPersona, Persona } from '$lib/stores/persona'
|
||||
import type { Signer } from 'ethers'
|
||||
import type { DraftChat } from '$lib/stores/chat'
|
||||
import { InMemoryAndIPFS } from './in-memory-and-ipfs'
|
||||
import { ZkitterAdapter } from './zkitter'
|
||||
import { Firebase } from './firebase'
|
||||
import { ADAPTER } from '$lib/constants'
|
||||
@ -37,7 +36,7 @@ export interface Adapter {
|
||||
joinPersona(personaId: string): Promise<void>
|
||||
}
|
||||
|
||||
export const adapters = ['in-memory', 'zkitter', 'firebase'] as const
|
||||
export const adapters = ['zkitter', 'firebase'] as const
|
||||
export type AdapterName = (typeof adapters)[number]
|
||||
export const adapterName: AdapterName = getFromLocalStorage<AdapterName>(
|
||||
'adapter',
|
||||
@ -46,9 +45,6 @@ export const adapterName: AdapterName = getFromLocalStorage<AdapterName>(
|
||||
|
||||
let adapter: Adapter
|
||||
switch (adapterName) {
|
||||
case 'in-memory':
|
||||
adapter = new InMemoryAndIPFS()
|
||||
break
|
||||
case 'zkitter':
|
||||
adapter = new ZkitterAdapter()
|
||||
break
|
||||
|
||||
@ -1,27 +1,12 @@
|
||||
<script lang="ts">
|
||||
import Button from '$lib/components/button.svelte'
|
||||
import Header from '$lib/components/header.svelte'
|
||||
import Container from '$lib/components/container.svelte'
|
||||
import Textarea from '$lib/components/textarea.svelte'
|
||||
import { tokens } from '$lib/stores/tokens'
|
||||
import Divider from '$lib/components/divider.svelte'
|
||||
import { adapterName, adapters, type AdapterName } from '$lib/adapters'
|
||||
import Dropdown from '$lib/components/dropdown.svelte'
|
||||
import DropdownItem from '$lib/components/dropdown-item.svelte'
|
||||
import Select from '$lib/components/select.svelte'
|
||||
import { saveToLocalStorage } from '$lib/utils'
|
||||
import { startNewEpoch } from '$lib/adapters/in-memory-and-ipfs'
|
||||
|
||||
let goTokenValue = $tokens.go.toFixed()
|
||||
let repTokenValue = $tokens.repTotal.toFixed()
|
||||
|
||||
function updateTokens() {
|
||||
tokens.update((tokens) => {
|
||||
tokens.go = parseInt(goTokenValue)
|
||||
tokens.repTotal = parseInt(repTokenValue)
|
||||
return tokens
|
||||
})
|
||||
}
|
||||
|
||||
function changeAdapter(adapterName: AdapterName) {
|
||||
saveToLocalStorage('adapter', adapterName)
|
||||
@ -43,21 +28,6 @@
|
||||
</Dropdown>
|
||||
</section>
|
||||
<Divider />
|
||||
{#if adapterName === 'in-memory'}
|
||||
<section>
|
||||
<h2>Epoch</h2>
|
||||
<p>Epoch duration: {$tokens.epochDuration / 1000} seconds</p>
|
||||
<p>Time to end epoch: {($tokens.timeToEpoch / 1000).toFixed()} seconds</p>
|
||||
<Button label="End epoch now" variant="secondary" on:click={startNewEpoch} />
|
||||
</section>
|
||||
<Divider />
|
||||
<section>
|
||||
<Textarea label="Available GO token value" bind:value={goTokenValue} />
|
||||
<Textarea label="Total REP token" bind:value={repTokenValue} />
|
||||
<Button label="Update" on:click={updateTokens} />
|
||||
</section>
|
||||
<Divider />
|
||||
{/if}
|
||||
</Container>
|
||||
|
||||
<style lang="scss">
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user