Added Rust Client snippets

Author: oskardudycz

README.md

@@ -15,7 +15,8 @@ We're open for any contribution. If you noticed some inconsistency, missing piec
 GRPC Clients:
 - C# - [see more](https://github.com/EventStore/EventStore-Client-Dotnet/tree/master/samples)
 - NodeJS - [see more](./samples/grpc/nodejs/)
-- Java# - [see more](https://github.com/EventStore/EventStoreDB-Client-Java/tree/trunk/db-client-java/src/test/java/com/eventstore/dbclient/samples)
+- Java - [see more](https://github.com/EventStore/EventStoreDB-Client-Java/tree/trunk/db-client-java/src/test/java/com/eventstore/dbclient/samples)
+- Rust - [see more](https://github.com/EventStore/EventStoreDB-Client-Rust/tree/master/examples)
 
 ## Local development
 

docs/.vuepress/enhanceApp.js

@@ -8,6 +8,7 @@ import Prism from "vue-prism-component";
 import "prismjs/components/prism-csharp";
 import "prismjs/components/prism-java";
 import "prismjs/components/prism-yaml";
+import "prismjs/components/prism-rust";
 import "prismjs/components/prism-bash";
 import * as gtm from "./gtm/inject";
 import Vuex from "vuex";

docs/clients/grpc/appending-events/README.md

@@ -19,6 +19,10 @@ The simplest way to append an event to EventStoreDB is to create an `EventData`
 
 <<< @/docs/clients/java/generated/0.7/samples/appending_events/AppendingEvents.java#append-to-stream
 </xode-block>
+<xode-block title="Rust">
+
+<<< @/docs/clients/rust/generated/0.9.9/samples/appending_events.rs#append-to-stream
+</xode-block>
 </xode-group>
 
 As you can see `AppendToStream` method allows takes a collection of `EventData`, which makes possible saving more than one event in a single batch.
@@ -52,6 +56,10 @@ For example:
 
 <<< @/docs/clients/java/generated/0.7/samples/appending_events/AppendingEvents.java#append-duplicate-event
 </xode-block>
+<xode-block title="Rust">
+
+<<< @/docs/clients/rust/generated/0.9.9/samples/appending_events.rs#append-duplicate-event
+</xode-block>
 </xode-group>
 
 will result in only a single event being appended.
@@ -97,6 +105,10 @@ For example if we try and append the same record twice expecting both times that
 
 <<< @/docs/clients/java/generated/0.7/samples/appending_events/AppendingEvents.java#append-with-no-stream
 </xode-block>
+<xode-block title="Rust">
+
+<<< @/docs/clients/rust/generated/0.9.9/samples/appending_events.rs#append-with-no-stream
+</xode-block>
 </xode-group>
 
 There are three available stream states: 
@@ -119,6 +131,10 @@ This check can be used to implement optimistic concurrency. When you retrieve a
 
 <<< @/docs/clients/java/generated/0.7/samples/appending_events/AppendingEvents.java#append-with-concurrency-check
 </xode-block>
+<xode-block title="Rust">
+
+<<< @/docs/clients/rust/generated/0.9.9/samples/appending_events.rs#append-with-concurrency-check
+</xode-block>
 </xode-group>
 
 <!-- ## Options
@@ -140,4 +156,8 @@ You can provide user credentials to be used to append the data as follows. This
 
 <<< @/docs/clients/java/generated/0.7/samples/appending_events/AppendingEvents.java#overriding-user-credentials
 </xode-block>
+<xode-block title="Rust">
+
+<<< @/docs/clients/rust/generated/0.9.9/samples/appending_events.rs#overriding-user-credentials
+</xode-block>
 </xode-group>

import/import-client-docs.js

@@ -42,38 +42,37 @@ async function replaceCodePath(mdPath, samplesPath) {
     await sh(replaceCommand);
 }
 
-async function tryCopy(pathElements, subFolderName, destinationPath) {
-    const sourcePath = path.join(...[...pathElements, subFolderName]);
+async function tryCopy(pathElements, destinationPath) {
+    const sourcePath = path.join(...pathElements);
 
     if (!fs.existsSync(sourcePath)) {
         log.info(`${sourcePath} does not exist, skipping...`);
         return false;
     }
 
-    log.info(`${subFolderName}  exist, copying...`);
+    log.info(`${sourcePath}  exist, copying...`);
 
     await fsExtra.copy(sourcePath, destinationPath);
 
     return true;
 }
 
-async function copyDocsAndSamples(clientRepo, repoLocation, docsLocation, id, tag, relativePath) {
+async function copySamples(clientRepo, repoLocation, destinationPath, id, tag, relativePath) {
     log.info(`checking out ${tag}...`);
     await clientRepo.checkout(tag);
 
-    const pathElements = [repoLocation, ...(relativePath || ['docs'])];
+    const pathElements = [repoLocation, ...relativePath];
 
-    const samplesDestinationPath = path.join(docsLocation, id, 'samples');
-    const docsDestinationPath = path.join(docsLocation, id);
+    const destinationPathWithId = path.join(destinationPath, id);
+    const samplesDestinationPath = path.join(destinationPathWithId, 'samples');
 
-    const wereDocsCopied = await tryCopy(pathElements, 'docs', docsDestinationPath);
-    const wereSamplesCopied = await tryCopy(pathElements, 'samples', samplesDestinationPath);
+    const wereSamplesCopied = await tryCopy(pathElements, samplesDestinationPath);
 
-    if (!wereDocsCopied && !wereSamplesCopied) {
+    if (!wereSamplesCopied) {
         return;
     }
 
-    await replaceCodePath(docsDestinationPath, samplesDestinationPath);
+    await replaceCodePath(destinationPathWithId, samplesDestinationPath);
 
     return {path: path.join('generated', id), version: id.substr(1) + ' gRPC'};
 }
@@ -84,10 +83,10 @@ async function main() {
 
     for (const repo of repos) {
         const repoPath = path.join('docs', repo.basePath);
-        const docsLocation = path.join(repoPath, 'generated');
+        const samplesLocation = path.join(repoPath, 'generated');
         const repoLocation = path.join('temp', repo.id);
 
-        await safeRmdir(docsLocation);
+        await safeRmdir(samplesLocation);
         await git.clone(repo.repo, repoLocation);
 
         const clientRepo = simpleGit(repoLocation);
@@ -108,11 +107,11 @@ async function main() {
             .filter(i => i)
 
         if (deployCurrent) {
-            definition[0].versions.push(await copyDocsAndSamples(clientRepo, repoLocation, docsLocation, tags.slice(-1)[0], repo.currentBranch, repo.relativePath));
+            definition[0].versions.push(await copySamples(clientRepo, repoLocation, samplesLocation, tags.slice(-1)[0], repo.currentBranch, repo.relativePath));
         }
 
         for (let i = 0; i < tags.length - 1; i++) {
-            const version = await copyDocsAndSamples(clientRepo, repoLocation, docsLocation, tags[i], tags[i + 1]);
+            const version = await copySamples(clientRepo, repoLocation, samplesLocation, tags[i], tags[i + 1], repo.relativePath);
 
             if (version !== undefined) {
                 definition[0].versions.push(version);

import/repos.json

@@ -3,16 +3,24 @@
     "id": "dotnet-client",
     "group": ".NET SDK",
     "basePath": "clients/dotnet",
-    "relativePath": [],
+    "relativePath": ["samples"],
     "currentBranch": "master",
     "repo": "https://github.com/EventStore/EventStore-Client-Dotnet.git"
   },
   {
     "id": "java-client",
     "group": "Java SDK",
     "basePath": "clients/java",
-    "relativePath": ["db-client-java","src","test","java","com","eventstore","dbclient"],
+    "relativePath": ["db-client-java","src","test","java","com","eventstore","dbclient", "samples"],
     "currentBranch": "trunk",
     "repo": "https://github.com/EventStore/EventStoreDB-Client-Java.git"
+  },
+  {
+    "id": "rust-client",
+    "group": "Rust SDK",
+    "basePath": "clients/rust",
+    "relativePath": ["examples"],
+    "currentBranch": "snippets_fixes_for_docs",
+    "repo": "https://github.com/EventStore/EventStoreDB-Client-Rust.git"
   }
 ]