logfmt 0.1.0

A set of tools for working with logfmt-style log lines.

logfmt-dart

"logfmt" is the name of a key-value logging convention, where log lines are formatted as "key=value" pairs.

This package decodes individual log lines or streams of log lines. Individual log lines are decoded as Map<String, dynamic> objects, and streams passing through the streamDecoder transform will emit Map<String, dynamic> objects, as well.

Usage

#decode

Given a logfmt-style log line, decode it into a Map<String, dynamic> using #decode:

import 'package:logfmt/logfmt.dart' as logfmt;
import 'package:unittest/unittest.dart';

void main() {
  test('key=value pairs of non-null and non-boolean strings decode into [Map<String, String>].', () {
    expect(logfmt.decode('key=value'), equals({ 'key': 'value' }));
  });
  
  test('"flag"s are decoded into [Map<String, bool>] where `bool` is `true`.', () {
    expect(logfmt.decode('flag'), equals({ 'flag': true }));
  });
  
  test('Pairs with "true" or "false" as values are decoded into [Map<String, bool>], as appropriate.', () {
    expect(logfmt.decode('key=false'), equals({ 'key': false }));
  });
  
  test('Pairs with "null" values are decoded into [Map<String, Null>].', () {
    expect(logfmt.decode('key=null'), equals({ 'key': null }));
  });
  
  test('Quoted keys and values are preserved.', () {
    expect(logfmt.decode('"quoted key"="quoted value"'), equals({ 'quoted key': 'quoted value' }));
  });
}

streamDecoder

A stream of lines can be sent to the streamDecoder transformer, which will return a stream emitting Map<String, dynamic> objects.

import 'dart:convert';
import 'dart:io';
import 'package:logfmt/logfmt.dart' as logfmt;

void main() {
  new File('test/log.txt').openRead()
    .transform(new Utf8Decoder())
    .transform(new LineSplitter())
    .transform(logfmt.streamDecoder())
    .listen((Map<String, dynamic> map) {
      print(map);
    });
}

Todo

• Implement #encode and piping to a stream.
• Implement a timer.
• Implement an example request logger.