Minimalistic analytics library used by Dart Server and try.dartlang.org

microlytics/lib/channels.dart

+// Copyright (c) 2014, the Dart project authors.  Please see the AUTHORS file
+// for details. All rights reserved. Use of this source code is governed by a
+// BSD-style license that can be found in the LICENSE file.
+
+library microlytics.channels;
+
+import 'dart:async';
+
+final String ANALYTICS_URL = "https://www.google-analytics.com/collect";

[ahe, 2014/09/03 08:51:31]

I'm not sure this is related to channels.

[lukechurch, 2014/09/04 12:58:41]

True. I thought that having a separate class to declare a single constant was
design overkill. This was a pragmatic tradeoff.

+
+abstract class Channel {
+  void sendData(String data);
+  void shutdown() {}
+}
+
+/// [Channel] that implements a leaky bucket
+/// algorithm to provide rate limiting.
+/// See (http://en.wikipedia.org/wiki/Leaky_bucket)

[ahe, 2014/09/03 08:51:31]

Add period, and use [] instead of ().

[lukechurch, 2014/09/04 12:58:41]

Done.

+class RateLimitingBufferedChannel extends Channel {
+  final List<String> _buffer = <String>[];
+  final Channel _innerChannel;
+  final int bufferSizeLimit;
+  Timer _timer;
+
+  RateLimitingBufferedChannel(
+      this._innerChannel,
+      { this.bufferSizeLimit: 10,

[ahe, 2014/09/03 08:51:31]

Remove space after {.

[lukechurch, 2014/09/04 12:58:41]

Done.

+        double packetsPerSecond: 1.0}) {
+    if (!(packetsPerSecond > 0)) {
+      throw new ArgumentError("packetsPerSecond must be larger than zero");
+    }
+
+    int transmitDelay = (1000 / packetsPerSecond).floor();
+    _timer = new Timer(new Duration(milliseconds: transmitDelay), () {
+      _onTimerTick();
+    });
+  }
+
+  void _onTimerTick() {
+    if (_buffer.length > 0) {
+      String item = _buffer.removeLast();
+      _innerChannel.sendData(item);
+    }
+  }
+
+  void sendData(String data) {
+    if (_buffer.length >= bufferSizeLimit) return;
+    _buffer.add(data);
+  }
+
+  void shutdown() {
+    _timer.cancel();
+    _innerChannel.shutdown();
+  }
+}