Update Diffusion Examples to 6.7.2

dimejiogunyoye · dimejiogunyoye · commit 6e6fa1e88c2f · 2021-10-28T13:44:27.000+01:00
diff --git a/android/README.md b/android/README.md
@@ -14,7 +14,7 @@ range query API does not use the `java.time` classes.
 
 You can download the Android client library from the following location:
 
-*   [https://www.pushtechnology.com/developers/cloud/latest/#android-sdk](https://www.pushtechnology.com/developers/cloud/latest/#android-sdk)
+*   [http://download.pushtechnology.com/cloud/latest/sdks.html](http://download.pushtechnology.com/cloud/latest/sdks.html#android)
 
 The client library is also available in the `clients` directory of the Diffusion installation.
 
diff --git a/apple/README.md b/apple/README.md
@@ -11,6 +11,6 @@ runtime platform. They will require minimum modification to run on either OS X o
 
 You can download the Apple client libraries from the following location:
 
-*   [https://www.pushtechnology.com/developers/cloud/latest/#apple-sdk](https://www.pushtechnology.com/developers/cloud/latest/#apple-sdk)
+*   [http://download.pushtechnology.com/cloud/latest/sdks.html](http://download.pushtechnology.com/cloud/latest/sdks.html#apple)
 
 The client libraries are also available in the `clients` directory of the Diffusion installation.
diff --git a/c/README.md b/c/README.md
@@ -14,7 +14,7 @@ The C API is available for the following operating systems:
 
 You can download the C client libraries from the following locations:
 
-*   Download from [https://www.pushtechnology.com/developers/cloud/latest/#c-sdk](https://www.pushtechnology.com/developers/cloud/latest/#c-sdk)
+*   Download from [our website](http://download.pushtechnology.com/cloud/latest/sdks.html#c)
 
 *   The client libraries are also available in the `clients` directory of the Diffusion server installation.
 
diff --git a/dotnet/README.md b/dotnet/README.md
@@ -13,6 +13,6 @@ In order for all examples to work you have to pull in
 
 You can also download the client library from the following locations:
 
-*   Download from [https://www.pushtechnology.com/developers/cloud/latest/#dotnet-sdk](https://www.pushtechnology.com/developers/cloud/latest/#dotnet-sdk)
+*   Download from [our website](http://download.pushtechnology.com/cloud/latest/sdks.html#dotnet)
 
 *   The client library is also available in the `clients` directory of the Diffusion server installation.
diff --git a/java/README.md b/java/README.md
@@ -18,6 +18,6 @@ The Java client library is available from the [Push Technology Maven repository]
 
 You can also download the Java client library from the following locations:
 
-*   Download from [https://www.pushtechnology.com/developers/cloud/latest/#java-sdk](https://www.pushtechnology.com/developers/cloud/latest/#java-sdk)
+*   Download from [our website](http://download.pushtechnology.com/cloud/latest/sdks.html#java)
 
 *   The client library is also available in the `clients` directory of the Diffusion installation.
diff --git a/java/pom.xml b/java/pom.xml
@@ -11,7 +11,7 @@
 
     <groupId>com.pushtechnology.diffusion</groupId>
     <artifactId>diffusion-api-java-examples</artifactId>
-    <version>6.7.1</version>
+    <version>6.7.2</version>
     <packaging>jar</packaging>
     <description>Diffusion public API examples.</description>
 
@@ -54,7 +54,7 @@
         <dependency>
             <groupId>com.pushtechnology.diffusion</groupId>
             <artifactId>diffusion-client</artifactId>
-            <version>6.7.1</version>
+            <version>6.7.2</version>
             <scope>runtime</scope>
         </dependency>
 
diff --git a/js/README.md b/js/README.md
@@ -13,6 +13,6 @@ You can install the Node version of the JavaScript client library with the follo
 
 You can download the browser version of the JavaScript client library from the following locations:
 
-*   Download from [https://www.pushtechnology.com/developers/cloud/latest/#js-sdk](https://www.pushtechnology.com/developers/cloud/latest/#js-sdk)
+*   Download from [our website](https://www.pushtechnology.com/developers/release/latest/#js-sdk)
 
 *   The client libraries are also available in the `clients` directory of the Diffusion installation.
diff --git a/js/package.json b/js/package.json
@@ -1,13 +1,13 @@
 {
   "name": "diffusion-examples",
-  "version": "6.7.1",
+  "version": "6.7.2",
   "description": "Examples for using the Diffusion JavaScript client",
   "main": "index.js",
   "directories": {
     "example": "examples"
   },
   "license": "Apache-2.0",
   "dependencies": {
-    "diffusion": "6.7.1"
+    "diffusion": "6.7.2"
   }
 }
diff --git a/python/examples/metrics/session_metrics.py b/python/examples/metrics/session_metrics.py
@@ -29,10 +29,13 @@ async def main():
     ) as session:
         metrics = session.metrics
         session_filter = "x is 'y'"
-        
+
         try:
-            print(f"Adding the session metric collector 'Test' with session filter '{session_filter}'.")
-        
+            print(
+                f"""\
+Adding the session metric collector 'Test' with session filter '{session_filter}'."""
+            )
+
             collector = (
                 SessionMetricCollectorBuilder()
                 .group_by_properties("$Location")
@@ -54,10 +57,12 @@ async def main():
 
             for session_metric_collector in listSessionMetricCollectors:
                 print(
-                    f"Name: '{session_metric_collector.Name}', "
-                    f"Session filter: '{session_metric_collector.session_filter}', "
-                    f"Exports to Prometheus: '{session_metric_collector.exports_to_prometheus}', "
-                    f"Removes metrics with no matches: '{session_metric_collector.removes_metrics_with_no_matches}'"
+                    f"""
+Name: '{session_metric_collector.name}',
+Session filter: '{session_metric_collector.session_filter}',
+Exports to Prometheus: '{session_metric_collector.exports_to_prometheus}',
+Removes metrics with no matches: '{session_metric_collector.removes_metrics_with_no_matches}'
+                    """
                 )
 
             for property in session_metric_collector.group_by_properties:
diff --git a/python/examples/metrics/topic_metrics.py b/python/examples/metrics/topic_metrics.py
@@ -32,7 +32,9 @@ async def main():
 
         try:
             print(
-                f"Adding the topic metric collector 'Test' with topic selector '{topic_selector}'."
+                f"""\
+Adding the topic metric collector 'Test' with topic selector '{topic_selector}'.
+                """
             )
 
             collector = (
diff --git a/python/examples/session_trees/session_trees.py b/python/examples/session_trees/session_trees.py
@@ -31,26 +31,37 @@ async def main():
              )
             await session.session_trees.put_branch_mapping_table(table)
 
-            print(f"Branch mapping table created for session tree branch '{table.session_tree_branch}'.")
+            print(f"""\
+Branch mapping table created for session tree branch '{table.session_tree_branch}'."""
+                  )
         except Exception as ex:
             print(f"Failed to create branch mapping table : {ex}.")
             return
 
         try:
             print("Retrieving session tree branches.")
-            list_session_tree_branches = await session.session_trees.get_session_tree_branches_with_mappings()
+            list_session_tree_branches = (
+                await session.session_trees.get_session_tree_branches_with_mappings()
+            )
         except Exception as ex:
             print(f"Failed to retrieve session tree branches : {ex}.")
             return
 
         try:
-            print(f"Retrieving branch mapping table:")
+            print("Retrieving branch mapping table:")
 
             for session_tree_branch in list_session_tree_branches:
-                branch_mapping_table = await session.session_trees.get_branch_mapping_table(session_tree_branch)
+                branch_mapping_table = await session.session_trees.get_branch_mapping_table(
+                    session_tree_branch
+                )
 
                 for branch_mapping in branch_mapping_table.branch_mappings:
-                    print(f"Session tree branch: '{session_tree_branch}', Session filter: '{branch_mapping.session_filter}', Topic tree branch: '{branch_mapping.topic_tree_branch}'");
+                    print(
+                        f"""\
+Session tree branch: '{session_tree_branch}',
+Session filter: '{branch_mapping.session_filter}',
+Topic tree branch: '{branch_mapping.topic_tree_branch}'"""
+                    )
         except Exception as ex:
             print(f"Failed to retrieve a branch mapping : {ex}.")
 
diff --git a/python/examples/topics/add_fallback_stream.py b/python/examples/topics/add_fallback_stream.py
@@ -1,6 +1,17 @@
+#  Copyright (c) 2021 Push Technology Ltd., All Rights Reserved.
+#
+#  Use is subject to license terms.
+#
+#  NOTICE: All information contained herein is, and remains the
+#  property of Push Technology. The intellectual and technical
+#  concepts contained herein are proprietary to Push Technology and
+#  may be covered by U.S. and Foreign Patents, patents in process, and
+#  are protected by trade secret or copyright law.
 """ Example of sending a request to a session filter. """
+
 import asyncio
 import diffusion
+import diffusion.features.topics as topics
 
 # Diffusion server connection information; same for both sessions
 # adjust as needed for the server used in practice
@@ -35,7 +46,7 @@ def on_unsubscribe(*, reason, topic_path, **kwargs):
 session_duration = 15
 
 # fallback stream object
-fallback_stream = diffusion.topics.ValueStreamHandler(
+fallback_stream = topics.ValueStreamHandler(
     data_type=topic_type,
     update=on_update,
     subscribe=on_subscribe,
diff --git a/python/examples/topics/add_value_stream.py b/python/examples/topics/add_value_stream.py
@@ -1,6 +1,17 @@
+#  Copyright (c) 2021 Push Technology Ltd., All Rights Reserved.
+#
+#  Use is subject to license terms.
+#
+#  NOTICE: All information contained herein is, and remains the
+#  property of Push Technology. The intellectual and technical
+#  concepts contained herein are proprietary to Push Technology and
+#  may be covered by U.S. and Foreign Patents, patents in process, and
+#  are protected by trade secret or copyright law.
 """ Example of sending a request to a session filter. """
+
 import asyncio
 import diffusion
+import diffusion.features.topics as topics
 
 # Diffusion server connection information; same for both sessions
 # adjust as needed for the server used in practice
@@ -35,7 +46,7 @@ def on_unsubscribe(*, reason, topic_path, **kwargs):
 session_duration = 15
 
 # value stream instance
-value_stream = diffusion.topics.ValueStreamHandler(
+value_stream = topics.ValueStreamHandler(
     data_type=topic_type,
     update=on_update,
     subscribe=on_subscribe,
diff --git a/python/requirements.txt b/python/requirements.txt
@@ -1,2 +1,2 @@
-diffusion==6.7.1
+diffusion==6.7.2
 jupyter
diff --git a/ts/README.md b/ts/README.md
@@ -10,6 +10,6 @@ You can install the Node version of the JavaScript client library including the
 
 You can download the TypeScript definitions separately from the following locations:
 
-*   Download from [https://www.pushtechnology.com/developers/cloud/latest/#js-sdk](https://www.pushtechnology.com/developers/cloud/latest/#js-sdk)
+*   Download from [our website](http://download.pushtechnology.com/cloud/latest/sdks.html#ts)
 
 *   The typescript definitions are also available in the `typescript` directory of the Diffusion installation.
diff --git a/ts/package.json b/ts/package.json
@@ -1,6 +1,6 @@
 {
   "name": "diffusion-examples",
-  "version": "6.7.1",
+  "version": "6.7.2",
   "description": "Examples for using the Diffusion JavaScript client",
   "main": "index.js",
   "directories": {
@@ -11,7 +11,7 @@
   },
   "license": "Apache-2.0",
   "dependencies": {
-    "diffusion": "6.7.1",
+    "diffusion": "6.7.2",
     "@types/node": "14.11.1",
     "typescript": "4.0.3"
   }

Original file line number	Diff line number	Diff line change
`@@ -1,13 +1,13 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "diffusion-examples",`
`3`		`- "version": "6.7.1",`
	`3`	`+ "version": "6.7.2",`
`4`	`4`	`"description": "Examples for using the Diffusion JavaScript client",`
`5`	`5`	`"main": "index.js",`
`6`	`6`	`"directories": {`
`7`	`7`	`"example": "examples"`
`8`	`8`	`},`
`9`	`9`	`"license": "Apache-2.0",`
`10`	`10`	`"dependencies": {`
`11`		`- "diffusion": "6.7.1"`
	`11`	`+ "diffusion": "6.7.2"`
`12`	`12`	`}`
`13`	`13`	`}`
Original file line number	Diff line number	Diff line change
`@@ -32,7 +32,9 @@ async def main():`
`32`	`32`
`33`	`33`	`try:`
`34`	`34`	`print(`
`35`		`- f"Adding the topic metric collector 'Test' with topic selector '{topic_selector}'."`
	`35`	`+ f"""\`
	`36`	`+Adding the topic metric collector 'Test' with topic selector '{topic_selector}'.`
	`37`	`+ """`
`36`	`38`	`)`
`37`	`39`
`38`	`40`	`collector = (`