diff options
author | Edi Feschiyan <553226+refresher@users.noreply.github.com> | 2020-06-18 13:12:31 +0300 |
---|---|---|
committer | Edi Feschiyan <553226+refresher@users.noreply.github.com> | 2020-06-18 13:12:31 +0300 |
commit | 80159d8789fe2ea0b36d84b83348813f67e18652 (patch) | |
tree | a997c5013257bdb7d02518d86c21595c15a33ced /services/gps.py | |
parent | 8a8b87e65c0b3d579f8ea420e23a9cd07528dfe1 (diff) |
Rearranging files for distribution, setup.py modifications
Diffstat (limited to 'services/gps.py')
-rw-r--r-- | services/gps.py | 56 |
1 files changed, 0 insertions, 56 deletions
diff --git a/services/gps.py b/services/gps.py deleted file mode 100644 index 1905e0f..0000000 --- a/services/gps.py +++ /dev/null @@ -1,56 +0,0 @@ -from aglbaseservice import AGLBaseService, AFBResponse -import asyncio -import os - - -class GPSService(AGLBaseService): - service = 'agl-service-gps' - parser = AGLBaseService.getparser() - parser.add_argument('--record', help='Begin recording verb ') - parser.add_argument('--location', help='Get current location', action='store_true') - - def __init__(self, ip, port=None): - super().__init__(api='gps', ip=ip, port=port, service='agl-service-gps') - - async def location(self): - return await self.request('location') - - async def record(self, state='on'): - return await self.request('record', {'state': state}) - - async def subscribe(self, event='location'): - return await super().subscribe(event=event) - - async def unsubscribe(self, event='location'): - return await super().subscribe(event=event) - - -async def main(loop): - args = GPSService.parser.parse_args() - gpss = await GPSService(ip=args.ipaddr, port=args.port) - - if args.loglevel: - gpss.logger.setLevel(args.loglevel) - - if args.record: - id = await gpss.record(args.record) - print(f'Sent gps record request with value {args.record} with messageid {id}') - print(AFBResponse(await gpss.response())) - - if args.location: - msgid = await gpss.location() - print(AFBResponse(await gpss.response())) - - if args.subscribe: - for event in args.subscribe: - id = await gpss.subscribe(event) - print(f'Subscribed for event {event} with messageid {id}') - print(AFBResponse(await gpss.response())) - - if args.listener: - async for response in gpss.listener(): - print(response) - -if __name__ == '__main__': - loop = asyncio.get_event_loop() - loop.run_until_complete(main(loop)) |