Task Example 2: Hashcat on Golem

This section contains steps you need to execute in order to run our hashcat password-recovery example. As this tutorial is designed to inspire you to create your own Golem applications, we will explain all the needed details of Golem application implementation.
This example illustrates following Golem features & aspects:
VM runtime
Task execution
Parallel task execution on multiple provider
Submitting multiple task sequences to a singleGolem engine
Setting timeout for commands run on a provider
Reading output from commands run on a provider
File transfer to/from provider's exe unit
What is hashcat?
​Hashcat is a command-line utility that finds unknown passwords from their known hashes.
Hashcat is a very powerful tool. It supports 320 hashing algorithms and 5 different attack types. We will use only the "phpass" algorithm and a simple brute-force attack.
First, we need to precisely define the "finding a password" problem. Let's assume we have a hash obtained from processing of an unknown password using the "phpass" algorithm.
Phpass is used as a hashing method by e.g. WordPress and Drupal. Those are free/open-source web frameworks used to run PHP-based websites.
The password hash is stored in in.hash file and the hash is:
1
$P$5ZDzPE45CLLhEx/72qt3NehVzwN2Ry/
Copied!
We're going to assume that we know the password mask. It is:
1
?a?a?a
Copied!
That means that the password consists of 3 alphanumeric characters.
Now we can try to find the password, matching the given hash and mask, by calling:
1
hashcat -a 3 -m 400 in.hash ?a?a?a
Copied!
The parameters are:
a 3 - use a brute-force attack. There are 5 other types of attacks.
m 400 - password is hashed with the phpass algorithm. There are 320 other alghoritms supported by hashcat.
in.hash - name of a file containing the hashed password
?a?a?a - mask to use
The complete hashcat arguments reference is available here: https://hashcat.net/wiki/doku.php?id=hashcat​
As a result of the above call, the hashcat.potfile will be created with the following content:
1
$P$5ZDzPE45CLLhEx/72qt3NehVzwN2Ry/:pas
Copied!
where pas is the password which had been unknown to us and was just retrieved by hashcat.
Obviously, for longer passwords, the presented usage of hashcat could be problematic as it would require a lot more processing time (e.g. days or even months) to find a password with such a naive method.
To showcase how a similar problem can be resolved faster, we created the Golem version of hashcat. It uses the computing power of many providers at the same time. Parallelized password recovery can be much quicker - instead of days or months, this Golem version is likely to solve the problem in hours.
Doings things in parallel
How to make hashcat work in parallel? The answer is quite simple: the keyspace concept. We can ask the tool to tell us what the size of the possibility space (keyspace) is for the given mask and algorithm:
1
hashcat --keyspace -a 3 ?a?a?a -m 400
Copied!
As a result, we will receive an answer in the standard output. In our case it is 9025.
Now we can divide the 0..9025 space into separate fragments. Assuming we want to allow our app to use up to 3 separate workers (which means up to 3 providers), those parts would be:
0..3008
3009..6016
6017..9025
To process only the part of the whole 0..9025 space, we use the --skip and --limit options:
1
hashcat -a 3 -m 400 in.hash --skip 3009 --limit 6016  ?a?a?a
Copied!
The above call will process the 3009..6016 part. If there is any result in that range it will be written to the hashcat.potfile.
Before we begin
In order to develop applications for the Golem network, you need to install yagna daemon on your machine. We're going to assume you're already familiar with the setup of the environment required to run Python high-level API examples. If you're not, please make sure you proceed through our quick primer to get up to speed:
Requestor development: a quick primer
Once you're done with the tutorial above, make sure you're again in yapapi's main directory and move to:
1
cd examples/yacat
Copied!
So now, we're going to assume that:
The yagna deamon is running in the background.
The YAGNA_APPKEY environment variable is set to the value of the generated app key.
The payment is initialized with yagna payment init -sender (please keep in mind that it needs initialization after each launch of yagna service run).
The virtual python environment for our tutorial is activated.
Dependencies are installed and the yapapi repository (containing the tutorial examples) is cloned.
In your current directory (examples/yacat) there are two files that will be used and discussed in this example:
yacat.Dockerfile - the Docker file used for the definition of the provider's container images
yacat.py - requestor agent's entry point which deals with orchestration of the container runs.
Let's get to work - the Dockerfile
Let's start with the Dockerfile (yacat.Dockerfile). Do we always need a dedicated Dockerfile for our own Golem application?
Golem is designed to use existing Docker images, so you can use any existing docker image. There are no Golem-specific conditions that need to be met by the image.
If there is (for example on the docker hub) no docker image that you need, you will have to create a custom one.
For the yacat example we're going to use an off-the-shelf hashcat image (dizcza/docker-hashcat:intel-cpu) and just slightly modify it for Golem. Resultant Dockerfile is included in the example as yacat.Dockerfile:
1
FROM dizcza/docker-hashcat:intel-cpu
2
​
3
VOLUME /golem/input /golem/output
4
WORKDIR /golem/entrypoint
Copied!
As Golem does not need any specific elements in the Dockerfile,yacat.Dockerfileis more or less a standard Dockerfile.
VOLUME: the input/output
The one thing we need to remember while preparing the Dockerfile is to define a place (or places) in the container file system that will be used for the file transfer. We are going to use input (from requestor to the provider) and output (from provider to the requestor) file transfers here.
The volume is defined in the last line of the above Dockerfile:
1
VOLUME /golem/input /golem/output
Copied!
This makes /golem/input and /golem/output locations we will use for our input/output file transfer. For the requestor agent code, which we are going to discuss in the next chapter, we need to know the volume (or volumes) name(s) and use it as a directory for the file transfers.
On the provider side, all the content of the VOLUME directories is stored in the provider's os file system.
All the changes in other (non VOLUME mounted) container directories content are kept in RAM. The rest of the VM image file system (not changed, non VOLUME mounted) content is stored as VM image in the provider's os file system.
Please mind that tasks within a single worker instance - so effectively part of the same activity on a given provider node - run within the same virtual machine and share the contents of a VOLUME between each other.
That means that as long as the execution takes place on the same provider, and thus, on the same filesystem, files in the VOLUME left over from one task execution will be present in a subsequent run.
If your provider-side code creates large temporary files, you should store them in the directory defined as VOLUME. Otherwise, the large files will be stored in RAM. RAM usually has a capacity limit much lower than disk space.
Important note about Docker's ENTRYPOINT
Because of how Golem's VM execution unit works, the Docker's usual ENTRYPOINT statement present in the Dockerfiles is effectively ignored and replaced with the exeunit's own entrypoint.
The net effect for you, the developer, is that - at least for the time being - you cannot rely on that feature in your Dockerfiles. Instead, you can pass the relevant commands from the requestor agent as part of the execution script after the image is deployed and started on provider's VM. This will be shown in the next step of this tutorial.
Build process
Now we may proceed with a regular Docker build, using yacat.Dockerfile:
1
docker build . -f yacat.Dockerfile -t yacat
Copied!
As Golem cannot currently use raw docker images and uses its own, optimized gvmkit image format, we have to convert our Docker image the following way:
1
pip install gvmkit-build
2
gvmkit-build yacat
3
gvmkit-build yacat --push
Copied!
The important fact is that the last of the above commands, will provide us with a gvmkit image hash, that looks like this:
1
2c17589f1651baff9b82aa431850e296455777be265c2c5446c902e9
Copied!
This hash will identify our image when our Golem application is run. Please copy and save it somewhere as in the requestor agent code, we will need to pass it to the Engine in order to have providers use the correct image for the container instances.
The details of docker image conversion are described here:
Converting an image from Docker to Golem
The requestor agent code
Let's look at the core of our hashcat example - the requestor agent. Please check the yacat.py file below.
The critical fragments of yacat.py will be described in the following sections of the tutorial so now, you can just do a quick scan over the big code block below.
1
#!/usr/bin/env python3
2
import argparse
3
import asyncio
4
from datetime import datetime, timedelta
5
import math
6
from pathlib import Path
7
import sys
8
from tempfile import gettempdir
9
from typing import AsyncIterable, List, Optional
10
​
11
from yapapi import Golem, Task, WorkContext
12
from yapapi.events import CommandExecuted
13
from yapapi.payload import vm
14
from yapapi.rest.activity import CommandExecutionError
15
​
16
examples_dir = Path(__file__).resolve().parent.parent
17
sys.path.append(str(examples_dir))
18
​
19
from utils import (
20
    build_parser,
21
    TEXT_COLOR_CYAN,
22
    TEXT_COLOR_DEFAULT,
23
    TEXT_COLOR_GREEN,
24
    TEXT_COLOR_RED,
25
    TEXT_COLOR_YELLOW,
26
    print_env_info,
27
    run_golem_example,
28
)
29
​
30
HASHCAT_ATTACK_MODE = 3  # stands for mask attack, hashcat -a option
31
KEYSPACE_OUTPUT_PATH = Path("/golem/output/keyspace")
32
​
33
# Ideally, this value should depend on the chunk size
34
MASK_ATTACK_TIMEOUT: timedelta = timedelta(minutes=30)
35
KEYSPACE_TIMEOUT: timedelta = timedelta(minutes=10)
36
​
37
arg_parser = build_parser("Run a hashcat attack (mask mode) on Golem network.")
38
arg_parser.epilog = (
39
    "Example invocation: ./yacat.py --mask '?a?a?a' --hash '$P$5ZDzPE45CLLhEx/72qt3NehVzwN2Ry/'"
40
)
41
arg_parser.add_argument("--hash", type=str, help="Target hash to be cracked", required=True)
42
arg_parser.add_argument(
43
    "--mask",
44
    type=str,
45
    help="Hashcat mask to be used for the attack. Example: a value of '?a?a?a' will "
46
    "try all 3-character combinations, where each character is mixalpha-numeric "
47
    "(lower and upper-case letters + digits) or a special character",
48
    required=True,
49
)
50
arg_parser.add_argument(
51
    "--chunk-size",  # affects skip and limit hashcat parameters
52
    type=int,
53
    help="Limit for the number of words to be checked as part of a single activity",
54
    default=4096,
55
)
56
arg_parser.add_argument(
57
    "--hash-type",
58
    type=int,
59
    help="Type of hashing algorithm to use (hashcat -m option). Default: 400 (phpass)",
60
    default=400,
61
)
62
arg_parser.add_argument(
63
    "--max-workers",
64
    type=int,
65
    help="The maximum number of nodes we want to perform the attack on (default is dynamic)",
66
    default=None,
67
)
68
​
69
# Container object for parsed arguments
70
args = argparse.Namespace()
71
​
72
​
73
async def compute_keyspace(context: WorkContext, tasks: AsyncIterable[Task]):
74
    """Worker script which computes the size of the keyspace for the mask attack.
75
​
76
    This function is used as the `worker` parameter to `Golem#execute_tasks`.
77
    It represents a sequence of commands to be executed on a remote provider node.
78
    """
79
    async for task in tasks:
80
        cmd = f"hashcat --keyspace " f"-a {HASHCAT_ATTACK_MODE} -m {args.hash_type} {args.mask}"
81
        s = context.new_script(timeout=KEYSPACE_TIMEOUT)
82
        s.run("/bin/bash", "-c", cmd)
83
​
84
        try:
85
            future_result = yield s
86
​
87
            # each item is the result of a single command on the provider (including setup commands)
88
            result: List[CommandExecuted] = await future_result
89
            # we take the last item since it's the last command that was executed on the provider
90
            cmd_result: CommandExecuted = result[-1]
91
​
92
            keyspace = int(cmd_result.stdout)
93
            task.accept_result(result=keyspace)
94
        except CommandExecutionError as e:
95
            raise RuntimeError(f"Failed to compute attack keyspace: {e}")
96
​
97
​
98
async def perform_mask_attack(ctx: WorkContext, tasks: AsyncIterable[Task]):
99
    """Worker script which performs a hashcat mask attack against a target hash.
100
​
101
    This function is used as the `worker` parameter to `Golem#execute_tasks`.
102
    It represents a sequence of commands to be executed on a remote provider node.
103
    """
104
    async for task in tasks:
105
        skip = task.data
106
        limit = skip + args.chunk_size
107
​
108
        output_name = f"yacat_{skip}.potfile"
109
        worker_output_path = f"/golem/output/{output_name}"
110
​
111
        script = ctx.new_script(timeout=MASK_ATTACK_TIMEOUT)
112
        script.run(f"/bin/sh", "-c", _make_attack_command(skip, limit, worker_output_path))
113
        try:
114
            output_file = Path(gettempdir()) / output_name
115
            script.download_file(worker_output_path, str(output_file))
116
​
117
            yield script
118
​
119
            with output_file.open() as f:
120
                result = f.readline()
121
                task.accept_result(result)
122
        finally:
123
            output_file.unlink()
124
​
125
​
126
def _make_attack_command(skip: int, limit: int, output_path: str) -> str:
127
    return (
128
        f"touch {output_path}; "
129
        f"hashcat -a {HASHCAT_ATTACK_MODE} -m {args.hash_type} "
130
        f"--self-test-disable --potfile-disable "
131
        f"--skip={skip} --limit={limit} -o {output_path} "
132
        f"'{args.hash}' '{args.mask}' || true"
133
    )
134
​
135
​
136
def _parse_result(potfile_line: str) -> Optional[str]:
137
    """Helper function which parses a single .potfile line and returns the password part.
138
​
139
    Hashcat uses its .potfile format to report results. In this format, each line consists of the
140
    hash and its matching word, separated with a colon (e.g. `asdf1234:password`).
141
    """
142
    if potfile_line:
143
        return potfile_line.split(":")[-1].strip()
144
    return None
145
​
146
​
147
async def main(args):
148
    package = await vm.repo(
149
        image_hash="055911c811e56da4d75ffc928361a78ed13077933ffa8320fb1ec2db",
150
        min_mem_gib=0.5,
151
        min_storage_gib=2.0,
152
    )
153
​
154
    async with Golem(
155
        budget=10.0,
156
        subnet_tag=args.subnet_tag,
157
        payment_driver=args.payment_driver,
158
        payment_network=args.payment_network,
159
    ) as golem:
160
        print_env_info(golem)
161
​
162
        start_time = datetime.now()
163
​
164
        completed = golem.execute_tasks(
165
            compute_keyspace,
166
            [Task(data="compute_keyspace")],
167
            payload=package,
168
            max_workers=1,
169
            timeout=KEYSPACE_TIMEOUT,
170
        )
171
​
172
        keyspace = 0
173
        async for task in completed:
174
            keyspace = task.result
175
​
176
        print(
177
            f"{TEXT_COLOR_CYAN}"
178
            f"Task computed: keyspace size count. The keyspace size is {keyspace}"
179
            f"{TEXT_COLOR_DEFAULT}"
180
        )
181
​
182
        data = [Task(data=c) for c in range(0, keyspace, args.chunk_size)]
183
        max_workers = args.max_workers or math.ceil(keyspace / args.chunk_size) // 2
184
​
185
        completed = golem.execute_tasks(
186
            perform_mask_attack,
187
            data,
188
            payload=package,
189
            max_workers=max_workers,
190
            timeout=MASK_ATTACK_TIMEOUT,
191
        )
192
​
193
        password = None
194
​
195
        async for task in completed:
196
            print(
197
                f"{TEXT_COLOR_CYAN}Task computed: {task}, result: {task.result}{TEXT_COLOR_DEFAULT}"
198
            )
199
​
200
            result = _parse_result(task.result)
201
            if result:
202
                password = result
203
​
204
        if password:
205
            print(f"{TEXT_COLOR_GREEN}Password found: {password}{TEXT_COLOR_DEFAULT}")
206
        else:
207
            print(f"{TEXT_COLOR_RED}No password found{TEXT_COLOR_DEFAULT}")
208
​
209
        print(f"{TEXT_COLOR_CYAN}Total time: {datetime.now() - start_time}{TEXT_COLOR_DEFAULT}")
210
​
211
​
212
if __name__ == "__main__":
213
    args = arg_parser.parse_args()
214
    run_golem_example(main(args), log_file=args.log_file)
Copied!
So what is happening here?
We start with a high-level overview of the steps performed by the requestor agent. In the next section we'll dig into the implementation details.
Compute keyspace size
The first step in the computation is to check the keyspace size. For this we only need to execute hashcat with --keyspace, as show in the section Doing things in parallel and read that command's output.
Define the tasks
Knowing the keyspace size we define the list of tasks to execute on providers. Recall from the section Doing things in parallel that we can run hashcat on a fragment of the whole keyspace, using the --skip and --limit parameters. In this step for each such fragment we define a separate task.
Knowing the number of tasks we can also determine the number of providers required to execute them in parallel. In this example we decided that the number of providers contracted for the work will be equal to the number of tasks divided by two. This does not necessarily mean that every provider will get exactly two tasks, even if the overall number of tasks is even, because:
When a provider is ready to execute a task, it takes up the next task from a common pool of tasks, so a fast provider may end up executing more tasks than a slow one.
Perform mask attack
Next, we can start looking for the password using multiple workers, executing the tasks on multiple providers at the same time.
In order to look for passwords in the given keyspace range, for each of the workers employed to perform our job, we are executing the following steps:
Executehashcat with proper --skip and --limit values on the provider
Get the hashcat_{skip}.potfile from the provider to the requestor
Parse the result from the .potfile
How does the code work?
The argument parser
The first big chunk of code, after imports and constants, is the definition of the argument parser that uses the argparse module for Python's standard library. The parser will allow us to pass arguments such as --mask and --max-workers, and it will print a nice argument description and an example invocation when we run the requestor script with --help.
The main function
Let's now jump to the main function which contains the main body of the requestor app. Its sole argument, args, contains information on the command-line arguments read by the argument parser.
1
async def main(args):
Copied!
Package definition
To tell the Golem platform what our requirements against the providers are, we are using the package object. The image_hash parameter points to the image that we want the containers to run - here we use the hash received from gvmkit-build. The min_mem_gib and min_storage_gib parameters specify memory and storage requirements for the provider.
1
 package = await vm.repo(
2
     image_hash="055911c811e56da4d75ffc928361a78ed13077933ffa8320fb1ec2db",
3
     min_mem_gib=0.5,
4
     min_storage_gib=2.0,
5
 )
Copied!
Golem engine
To run our tasks on the Golem network we need to create a Golem instance.
1
async with Golem(
2
    budget=10.0,
3
    subnet_tag=args.subnet_tag,
4
    payment_driver=args.payment_driver,
5
    payment_network=args.payment_network,
6
) as golem:
Copied!
The arguments are as follows:
budgetdefines maximal spendings for executing all the tasks with Golem
subnet_tag specifies the providers subnet to be used; it's best to leave the default value in place unless you mean to run your own network of test providers to test the app against,
next are the driver and network parameters that select the Ethereum blockchain and the payment driver for you; for example, you would not use the mainnet network for tests but you'll probably want to run the real-live tasks on the mainnet to be able to use all the providers that participate in the Golem network.
First call to execute_tasks: Computing keyspace size
With Golem instance running we may proceed with sending tasks to providers. For this we use the execute_tasks method.
1
completed = golem.execute_tasks(
2
    compute_keyspace,
3
    [Task(data="compute_keyspace")],
4
    payload=package,
5
    max_workers=1,
6
    timeout=KEYSPACE_TIMEOUT,
7
)
Copied!
This call tells Golem to execute a single task Task(data="compute_keyspace"). The task's data is not really used for keyspace size computation, it will be however printed to the console when the requestor app logs its progress, so we set it to be an informative description of the task.
The other arguments are:
the worker function that tells Golem what steps to perform on a provider in order to execute the tasks (in our case, there's only one task); here we pass the compute_keyspace function,
the package that we defined before,
the maximum number of worker instances we'd like to create -- or the maximum number of providers we want the tasks to be distributed to (for executing just one task it makes no sense to request more than one provider, so it's a bit redundant),
the total timeout for executing all tasks.
Due to limitations of the current Golem market implementation, please use timeout value between 8 minutes and 3 hours.
You can also specify the timeout value for the particular provider-side execution batch that is triggered by ctx.new_script(timeout=...).
The keyspace size can be read from the result attribute of the executed task. We use async for loop here to iterate over the completed tasks (even though we expect only one task).
1
        async for task in completed:
2
            keyspace = task.result
Copied!
Second call to execute_tasks: Performing the attack
Now we can split the whole keyspace into chunks of size args.chunk_size. For each chunk we create a separate Task. We've also decided to use the number of providers equal to the number of tasks divided by 2, so we define max_workers accordingly:
1
data = [Task(data=c) for c in range(0, keyspace, args.chunk_size)]
2
max_workers = args.max_workers or math.ceil(keyspace / args.chunk_size) // 2
Copied!
With the list of tasks prepared, we call golem.execute_tasks once more. This time, our worker function is perform_mask_attack:
1
        completed = golem.execute_tasks(
2
            perform_mask_attack,
3
            data,
4
            payload=package,
5
            max_workers=max_workers,
6
            timeout=MASK_ATTACK_TIMEOUT,
7
        )
Copied!
Each completed task will contain hashcat's output for the keyspace chunk represented by the task. We can parse this output using the auxiliary parse_result function:
1
        async for task in completed:
2
            print(
3
                f"{TEXT_COLOR_CYAN}Task computed: {task}, result: {task.result}{TEXT_COLOR_DEFAULT}"
4
            )
5
​
6
            result = _parse_result(task.result)
7
            if result:
8
                password = result
Copied!
Worker functions
With the main function covered, let's now have a look at the worker functions compute_keyspace and perform_mask_attack. Recall that worker functions are passed as arguments to execute_tasks, and are called once for each provider on which tasks are executed (more precisely, once for each activity, but in a typical scenario, including the current example, each provider executes just one activity).
compute_keyspace
The first worker is similar to the one that we've seen in Hello World! example, but the command we need to run on the provider is not date but hashcat with appropriate options:
1
hashcat --keyspace -a {HASHCAT_ATTACK_MODE} -m {args.hash_type} {args.mask}
Copied!
This instructs hashcat to compute and print the keyspace size. The following code sends the command to the provider, waits until it completes, and retrieves it's standard output:
1
    cmd = f"hashcat --keyspace " f"-a {HASHCAT_ATTACK_MODE} -m {args.hash_type} {args.mask}"
2
    s = context.new_script(timeout=KEYSPACE_TIMEOUT)
3
    s.run("/bin/bash", "-c", cmd)
4
​
5
    try:
6
        future_result = yield s
7
​
8
        # each item is the result of a single command on the provider (including setup commands)
9
        result: List[CommandExecuted] = await future_result
10
        # we take the last item since it's the last command that was executed on the provider
11
        cmd_result: CommandExecuted = result[-1]
12
        
13
        keyspace = int(cmd_result.stdout)
14
        task.accept_result(result=keyspace)
15
    except CommandExecutionError as e:
16
        raise RuntimeError(f"Failed to compute attack keyspace: {e}")
Copied!
perform_mask_attack
The second worker function, perform_mask_attack is more interesting. Unlike compute_keyspace, we make use of the data attribute that each task carries and use it to set --skip and --limitparameters to hashcat:
1
async for task in tasks:
2
    skip = task.data
3
    limit = skip + args.chunk_size
4
​
5
    output_name = f"yacat_{skip}.potfile"
6
    worker_output_path = f"/golem/output/{output_name}"
7
​
8
    script = ctx.new_script(timeout=MASK_ATTACK_TIMEOUT)
9
    script.run(f"/bin/sh", "-c", _make_attack_command(skip, limit, worker_output_path))
Copied!
The commands here are passed to an explicitly referenced /bin/sh shell. That's because any commands specified within script.run() are not, by themselves, run inside any shell.
The exact command to be run spans multiple lines so we construct it in a separate function _make_attack_command to make the worker code easier to follow. Let's take a look!
1
def _make_attack_command(skip: int, limit: int, output_path: str) -> str:
2
    return (
3
        f"touch {output_path}; "
4
        f"hashcat -a {HASHCAT_ATTACK_MODE} -m {args.hash_type} "
5
        f"--self-test-disable --potfile-disable "
6
        f"--skip={skip} --limit={limit} -o {output_path} "
7
        f"'{args.hash}' '{args.mask}' || true"
8
    )
Copied!
Couple of things to note here. The command touch {output_path} is there to make sure that the file {output_path} exists even if hashcat does not write any output (that happens if it does not find any password matching given hash).
The trailing || true is a standard trick to make sure that the exit code from the whole command is always 0-- hashcat returns a non-zero exit code if it fails to find any matching password and it causes the exe unit to report a command error to the requestor.
The option -o {output_path} tells hashcat to write output to a file. In the worker function we download the contents of this file to a temporary file created on the requestor:
1
output_file = Path(gettempdir()) / output_name
2
script.download_file(worker_output_path, str(output_file))
Copied!
The first line of this file (or the empty string) becomes the result of the completed task:
1
with output_file.open() as f:
2
    result = f.readline()
3
    task.accept_result(result)
Copied!
Running main in the event loop
Golem high-level API that we use to interact with the Golem network uses asynchronous programming a lot. The asynchronous execution starting point is the line
1
loop.run_until_complete(task)
Copied!
which schedules execution of main(args) in the event loop. This code resides in the run_golem_example function which abstracts some boilerplate necessary to run and handle errors while running the examples but which does little to illustrate interactions with Golem and its high-level API.
Now, as we know how yacat.py works, let's run it!
Example run
While in the /examples/yacat directory, type the following:
1
python3 yacat.py  --mask 'a?a?a' --hash '$P$5ZDzPE45CLLhEx/72qt3NehVzwN2Ry/'
Copied!
Please note that on Windows, you need to:
use python instead of python3
not use the quote character in the command
So the windows version is:
1
python yacat.py ?a?a?a $P$5ZDzPE45CLLhEx/72qt3NehVzwN2Ry/
Copied!
The above run should return "pas" as the recovered password.
A more computation-intensive example is:
1
python3 yacat.py --mask '?a?a?a?a' --hash '$H$5ZDzPE45C.e3TjJ2Qi58Aaozha6cs30' --chunk-size 10000
Copied!
The above command should execute 86 tasks on up to 43 providers and return "ABCD".
yacat.py supports a few optional parameters. To get help on those, please type:
1
python3 yacat.py --help
Copied!
One of the interesting options is to have log output to a file. This can be achieved by adding the following option to the yacat.py run:
1
--log-file LOG_FILE_NAME
Copied!
Other languages support
The yacat example is written in Python using Golem's Python High-Level API (YAPAPI). Golem currently supports writing requestor agents using JavaScript/TypeScript High-Level API (YAJAPI) also.
Next steps
The complete reference of the Python High-Level API (yapapi) is available here:
https://github.com/golemfactory/yagna-docs/blob/master/requestor-tutorials/task-processing-development/broken-reference/README.md
You can also have a look at our JavaScript/TypeScript API if you're interested in developing your requestor agent in JS/TS:
​https://github.com/golemfactory/yajsapi​
Closing words
Golem is waiting to serve your applications. Our decentralized - and open to everyone - platform is here (now in alpha).
We did our best to make developing Golem applications super easy.
Now it's time for your move!
And remember:
In case of any doubts or problems, you can always contact us on discord.
​https://chat.golem.network​