mirror of https://github.com/logos-co/wadoku.git
86 lines
2.6 KiB
Plaintext
Executable File
86 lines
2.6 KiB
Plaintext
Executable File
DEFAULT_CONFIG_FILE = "github.com/logos-co/wadoku/waku/config.json"
|
|
DEFAULT_RUN_PAIR = "lf"
|
|
|
|
|
|
def get_config_file(args):
|
|
return DEFAULT_CONFIG_FILE if not hasattr(args, "config") else args.config
|
|
|
|
|
|
def get_run_pair(args):
|
|
return DEFAULT_RUN_PAIR if not hasattr(args, "run_pair") else args.run_pair
|
|
|
|
|
|
def run(args):
|
|
print(args)
|
|
config_file = get_config_file(args)
|
|
run_pair = get_run_pair(args)
|
|
print("Reading the config from: %s" %config_file)
|
|
print("The runpair is %s" %run_pair)
|
|
config_json = read_file(src=config_file)
|
|
config = json.decode(config_json)
|
|
|
|
#input_file = config['input_file']
|
|
output_file = config['output_file']
|
|
duration = config['duration']
|
|
iat = config['iat']
|
|
loglvl = config['log_level']
|
|
ctopic = config['content_topic']
|
|
print(config)
|
|
|
|
|
|
if run_pair == "lf": # run lightpush and filter
|
|
|
|
waku_filtr = add_service(
|
|
service_id = "waku-filter",
|
|
config = struct(
|
|
image = "waku-filter:alpha",
|
|
entrypoint= ["/go/bin/waku-filter"],
|
|
cmd = [ "-o=" + "/go/bin/out/filter.out",
|
|
"-d=" + duration,
|
|
"-c=" + ctopic,
|
|
"-l=" + loglvl,
|
|
"-i=" + iat ],
|
|
),
|
|
)
|
|
waku_lpush = add_service(
|
|
service_id = "waku-lightpush",
|
|
config = struct(
|
|
image = "waku-lightpush:alpha",
|
|
entrypoint= ["/go/bin/waku-lightpush"],
|
|
cmd = [ "-o=" + "/go/bin/out/lightpush.out",
|
|
"-d=" + duration,
|
|
"-c=" + ctopic,
|
|
"-l=" + loglvl,
|
|
"-i=" + iat ],
|
|
),
|
|
)
|
|
print(waku_filtr, waku_lpush)
|
|
|
|
else: # run waku publish and subscribe
|
|
|
|
waku_sub = add_service(
|
|
service_id = "waku-subscribe",
|
|
config = struct(
|
|
image = "waku-subscribe:alpha",
|
|
entrypoint= ["/go/bin/waku-subscribe"],
|
|
cmd = [ "-o=" + "/go/bin/out/subscribe.out",
|
|
"-d=" + duration,
|
|
"-c=" + ctopic,
|
|
"-l=" + loglvl,
|
|
"-i=" + iat ],
|
|
),
|
|
)
|
|
waku_pub = add_service(
|
|
service_id = "waku-publish",
|
|
config = struct(
|
|
image = "waku-publish:alpha",
|
|
entrypoint= ["/go/bin/waku-publish"],
|
|
cmd = [ "-o=" + "/go/bin/out/publish.out",
|
|
"-d=" + duration,
|
|
"-c=" + ctopic,
|
|
"-l=" + loglvl,
|
|
"-i=" + iat ],
|
|
),
|
|
)
|
|
print(waku_sub, waku_pub)
|