from __future__ import absolute_import

import argparse
import time

from openxc.formats.json import JsonFormatter
from .common import device_options, configure_logging, select_device

def receive(message, **kwargs):
    message['timestamp'] = time.time()
    # TODO update docs on trace file format
    print(JsonFormatter.serialize(message))


def parse_options():
    parser = argparse.ArgumentParser(
            description="View a raw OpenXC data stream",
            parents=[device_options()])
    parser.add_argument("--corrupted",
            action="store_true",
            dest="show_corrupted",
            default=False, help="don't suppress corrupted messages from output")

    arguments = parser.parse_args()
    return arguments


def main():
    configure_logging()
    arguments = parse_options()

    source_class, source_kwargs = select_device(arguments)
    source = source_class(receive, **source_kwargs)
    source.start()

    while True:
        import time
        time.sleep(5)

from __future__ import absolute_import

import argparse
import time

from openxc.formats.json import JsonFormatter
from .common import device_options, configure_logging, select_device

def receive(message, **kwargs):
    message['timestamp'] = time.time()
    print(JsonFormatter.serialize(message))


def parse_options():
    parser = argparse.ArgumentParser(
            description="View a raw OpenXC data stream",
            parents=[device_options()])
    parser.add_argument("--corrupted",
            action="store_true",
            dest="show_corrupted",
            default=False, help="don't suppress corrupted messages from output")

    arguments = parser.parse_args()
    return arguments


def main():
    configure_logging()
    arguments = parse_options()

    source_class, source_kwargs = select_device(arguments)
    source = source_class(receive, **source_kwargs)
    source.start()

    while True:
        import time
        time.sleep(5)

Remove a resolved TODO - trace file formats now standardized.
Remove a resolved TODO - trace file formats now standardized.

  from __future__ import absolute_import
  
  import argparse
  import time
  
  from openxc.formats.json import JsonFormatter
  from .common import device_options, configure_logging, select_device
  
  def receive(message, **kwargs):
      message['timestamp'] = time.time()
-     # TODO update docs on trace file format
      print(JsonFormatter.serialize(message))
  
  
  def parse_options():
      parser = argparse.ArgumentParser(
              description="View a raw OpenXC data stream",
              parents=[device_options()])
      parser.add_argument("--corrupted",
              action="store_true",
              dest="show_corrupted",
              default=False, help="don't suppress corrupted messages from output")
  
      arguments = parser.parse_args()
      return arguments
  
  
  def main():
      configure_logging()
      arguments = parse_options()
  
      source_class, source_kwargs = select_device(arguments)
      source = source_class(receive, **source_kwargs)
      source.start()
  
      while True:
          import time
          time.sleep(5)
  
Remove a resolved TODO - trace file formats now standardized.
## Code Before:
from __future__ import absolute_import

import argparse
import time

from openxc.formats.json import JsonFormatter
from .common import device_options, configure_logging, select_device

def receive(message, **kwargs):
    message['timestamp'] = time.time()
    # TODO update docs on trace file format
    print(JsonFormatter.serialize(message))


def parse_options():
    parser = argparse.ArgumentParser(
            description="View a raw OpenXC data stream",
            parents=[device_options()])
    parser.add_argument("--corrupted",
            action="store_true",
            dest="show_corrupted",
            default=False, help="don't suppress corrupted messages from output")

    arguments = parser.parse_args()
    return arguments


def main():
    configure_logging()
    arguments = parse_options()

    source_class, source_kwargs = select_device(arguments)
    source = source_class(receive, **source_kwargs)
    source.start()

    while True:
        import time
        time.sleep(5)

## Instruction:
Remove a resolved TODO - trace file formats now standardized.
## Code After:
from __future__ import absolute_import

import argparse
import time

from openxc.formats.json import JsonFormatter
from .common import device_options, configure_logging, select_device

def receive(message, **kwargs):
    message['timestamp'] = time.time()
    print(JsonFormatter.serialize(message))


def parse_options():
    parser = argparse.ArgumentParser(
            description="View a raw OpenXC data stream",
            parents=[device_options()])
    parser.add_argument("--corrupted",
            action="store_true",
            dest="show_corrupted",
            default=False, help="don't suppress corrupted messages from output")

    arguments = parser.parse_args()
    return arguments


def main():
    configure_logging()
    arguments = parse_options()

    source_class, source_kwargs = select_device(arguments)
    source = source_class(receive, **source_kwargs)
    source.start()

    while True:
        import time
        time.sleep(5)
