feat: Streamline mycelium example and add server port config

- Remove unnecessary code from the example to improve clarity.
- Add a configurable server port to the `MyceliumStreamer`.

examples/data/deduped_mycelium_master.vsh

@@ -12,102 +12,5 @@ id := streamer.write(id: 1, value: 'Record 1')!
 println('ID: ${id}')
 
 master_data := streamer.read(id: id)!
-worker_data := streamer.read(id: id, worker_public_key: worker_public_key)!
-
-// assert master_data == worker_data
-
 master_data_str := master_data.bytestr()
-worker_data_str := worker_data.bytestr()
-
 println('Master data: ${master_data_str}')
-println('Worker data: ${worker_data_str}')
-
-// println('data: ${data.str()}')
-// println('streamer: ${streamer.master}')
-// mut db := ourdb.new('/tmp/ourdb')!
-// println('Database path: ${db.path}')
-
-// import freeflowuniverse.herolib.clients.mycelium
-// import freeflowuniverse.herolib.installers.net.mycelium_installer
-// import freeflowuniverse.herolib.data.ourdb
-// import freeflowuniverse.herolib.osal
-// import time
-// import os
-// import encoding.base64
-// import json
-
-// // NOTE: Before running this script, ensure that the mycelium binary is installed and in the PATH
-
-// const master_port = 9000
-// const slave_public_key = '46a9f9cee1ce98ef7478f3dea759589bbf6da9156533e63fed9f233640ac072c'
-// const slave_address = '59c:28ee:8597:6c20:3b2f:a9ee:2e18:9d4f'
-
-// // Struct to hold data for syncing
-// struct SyncData {
-// 	id    u32
-// 	data  string
-// 	topic string = 'db_sync'
-// }
-
-// mycelium.delete()!
-
-// // Initialize mycelium clients
-// mut master := mycelium.get()!
-// master.server_url = 'http://localhost:${master_port}'
-// master.name = 'master_node'
-
-// // Get public keys for communication
-// // master_inspect := mycelium.inspect(key_file_path: '/tmp/mycelium_server1/priv_key.bin')!
-// // println('Server 1 (Master Node) public key: ${master_inspect.public_key}')
-
-// // Initialize ourdb instances
-// mut db := ourdb.new(
-// 	record_nr_max:   16777216 - 1
-// 	record_size_max: 1024
-// 	path:            '/tmp/ourdb1'
-// 	reset:           true
-// )!
-
-// defer {
-// 	db.destroy() or { panic('failed to destroy db1: ${err}') }
-// }
-
-// // Receive messages
-// // Parameters: wait_for_message, peek_only, topic_filter
-// received := master.receive_msg(wait: true, peek: false, topic: 'db_sync')!
-// println('Received message from: ${received.src_pk}')
-// println('Message payload: ${base64.decode_str(received.payload)}')
-
-// // Store in master db
-// println('\nStoring data in master node DB...')
-// data := 'Test data for sync - ' + time.now().str()
-// id := db.set(data: data.bytes())!
-// println('Successfully stored data in master node DB with ID: ${id}')
-
-// // Create sync data
-// sync_data := SyncData{
-// 	id:   id
-// 	data: data
-// }
-
-// // Convert to JSON
-// json_data := json.encode(sync_data)
-
-// // Send sync message to slave
-// println('\nSending sync message to slave...')
-// msg := master.send_msg(
-// 	public_key: slave_public_key
-// 	payload:    json_data
-// 	topic:      'db_sync'
-// )!
-
-// println('Sync message sent with ID: ${msg.id} to slave with public key: ${slave_public_key}')
-
-// // master.reply_msg(
-// // 	id:         received.id
-// // 	public_key: received.src_pk
-// // 	payload:    'Got your message!'
-// // 	topic:      'db_sync'
-// // )!
-
-// // println('Message sent to slave with ID: ${msg.id}')

lib/data/ourdb/mycelium_streamer.v

@@ -13,6 +13,7 @@ pub mut:
 pub struct NewStreamerArgs {
 pub mut:
 	incremental_mode bool = true // default is true
+	server_port      int  = 9000 // default is 9000
 }
 
 fn new_db_streamer(args NewStreamerArgs) !OurDB {
@@ -38,7 +39,14 @@ pub fn new_streamer(args NewStreamerArgs) !MyceliumStreamer {
 		incremental_mode: args.incremental_mode
 		mycelium_client:  &mycelium.Mycelium{}
 	}
+
 	s.mycelium_client = mycelium.get()!
+	s.mycelium_client.server_url = 'http://localhost:${args.server_port}'
+	s.mycelium_client.name = 'master_node'
+
+	// Get public keys for communication
+	// inspect := mycelium.inspect(key_file_path: '/tmp/mycelium_server1/priv_key.bin')!
+	// println('Server 2 (slave Node) public key: ${slave_inspect.public_key}')
 	return s
 }