Library subscribe

Example

library-subscribe.py
 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
#!/usr/bin/env python3

import asab
import asab.library
import asab.zookeeper


class MyApplication(asab.Application):

    def __init__(self):

        super().__init__()
        asab.Config["library"]["providers"] = "git+https://github.com/TeskaLabs/asab.git"

        self.LibraryService = asab.library.LibraryService(
            self,
            "LibraryService",
        )

        # Continue only if the library is ready
        self.PubSub.subscribe("Library.ready!", self.on_library_ready)
        self.PubSub.subscribe("Library.change!", self.on_library_change)

        # NOTE: Git Provider periodically pulls changes once per minute


    async def on_library_ready(self, event_name, library=None):
        items = await self.LibraryService.list("/", recursive=True)
        print("# Library\n")
        for item in items:
            print(" *", item)
        print("\n===")

        # Add subscription for changes in paths
        await self.LibraryService.subscribe(["/asab"])

    def on_library_change(self, msg, provider, path):
        print("\N{rabbit} New changes in the library found by provider: '{}'".format(provider))


if __name__ == '__main__':
    app = MyApplication()
    app.run()