Thursday, June 28, 2012

Calculate the exponential moving average of a stream of numbers

  1. public static IEnumerable<double> ExponentialMovingAverage(this IEnumerable<double> source, double alpha)
  2. {
  3. double? last = null;
  4. return source.Select(
  5. value =>
  6. {
  7. var average = last != null ? alpha*value + (1 - alpha)*last.Value : value;
  8. last = average;
  9. return average;
  10. });
  11. }

Thursday, February 16, 2012

Create a fast compiled method invoker using LINQ

  1. var method = new Func<double, double, double>(Math.Pow).Method;
  2. var parameter = Expression.Parameter(typeof(object[]));
  3. var args = method.GetParameters()
  4. .Select((param, i) => Expression.Convert(
  5. Expression.ArrayIndex(parameter, Expression.Constant(i)), param.ParameterType));
  6. var expr = Expression.Lambda<Func<object[], object>>(
  7. Expression.Convert(Expression.Call(method, args), typeof(object)), parameter);
  8. var invoker = expr.Compile();
  9. var result = invoker(new object[] {Math.PI, 2.0});

Friday, February 10, 2012

Create a Google calendar event in an existing calendar

  1. var credentials = new GDataCredentials(userName, password);
  2. var service = new CalendarService(null) {Credentials = credentials};
  3. var query = new CalendarQuery("https://www.google.com/calendar/feeds/default/owncalendars/full");
  4. var feed = service.Query(query);
  5. var eventFeedLink = feed.Entries.Cast<CalendarEntry>()
  6. .Where(item => item.Title.Text == calendarName)
  7. .SelectMany(item => item.Links)
  8. .First(link => link.Rel == GDataParserNameTable.NSGCal + "#eventFeed");
  9. var entry = new EventEntry(title) {Times = {new When(start, end, allDay)}};
  10. service.Insert(new Uri(eventFeedLink.AbsoluteUri), entry);
Google Data API .NET client library

Thursday, February 2, 2012

Page through potentially large NHibernate criteria query results

  1. public static IEnumerable<T> Enumerate<T>(this ICriteria criteria, int pageSize = 1000)
  2. {
  3. var entityCount = CriteriaTransformer.TransformToRowCount(criteria).UniqueResult<int>();
  4. var pageCount = (int) Math.Ceiling(entityCount/(double) pageSize);
  5. criteria = CriteriaTransformer.Clone(criteria).SetMaxResults(pageSize);
  6. return Enumerable.Range(0, pageCount)
  7. .SelectMany(pageNum => criteria.SetFirstResult(pageNum*pageSize).List<T>());
  8. }
NHibernate

Friday, January 20, 2012

Create a YouTube playlist containing all the uploads of a given user

  1. var credentials = new GDataCredentials(userName, password);
  2. var service = new YouTubeService(applicationName, developerKey) {Credentials = credentials};
  3. var entry = new AtomEntry {Title = {Text = playlistName}};
  4. entry = service.Insert(new Uri(YouTubeQuery.CreatePlaylistsUri(null)), entry);
  5. var id = ((XmlExtension) entry.FindExtension("playlistId", YouTubeNameTable.NSYouTube)).Node.InnerText;
  6. var batchUri = new Uri(string.Format("https://gdata.youtube.com/feeds/api/playlists/{0}/batch", id));
  7. var query = new YouTubeQuery(YouTubeQuery.CreateUserUri(sourceUser)) {StartIndex = 1};
  8. AtomFeed feed;
  9. do
  10. {
  11. feed = service.Query(query);
  12. service.Batch(feed, batchUri);
  13. query.StartIndex += feed.Entries.Count;
  14. } while (query.StartIndex < feed.TotalResults);
Google Data API .NET client library

Sunday, January 8, 2012

List the users of a TFS project associated with a local workspace path

  1. var workspace = Workstation.Current.GetLocalWorkspaceInfo(path);
  2. var tfs = new TfsTeamProjectCollection(workspace.ServerUri);
  3. var gss = tfs.GetService<IGroupSecurityService>();
  4. var grp = gss.ReadIdentity(SearchFactor.EveryoneApplicationGroup, null, QueryMembership.Expanded);
  5. var names = gss.ReadIdentities(SearchFactor.Sid, grp.Members, QueryMembership.None)
  6. .Where(identity => identity.Type == IdentityType.WindowsUser)
  7. .Select(identity => string.Format(@"{0}\{1}", identity.Domain, identity.AccountName))
  8. .ToArray();

Friday, January 6, 2012

Quartz scheduler job that re-triggers itself on completion

  1. public class RetriggerJob : IInterruptableJob
  2. {
  3. private bool _interrupted;
  4. public void Execute(IJobExecutionContext context)
  5. {
  6. Thread.Sleep(1000);
  7. if (_interrupted)
  8. {
  9. return;
  10. }
  11. context.Scheduler.TriggerJob(context.JobDetail.Key);
  12. if (_interrupted)
  13. {
  14. context.Scheduler.Interrupt(context.JobDetail.Key);
  15. }
  16. }
  17. public void Interrupt()
  18. {
  19. _interrupted = true;
  20. }
  21. }
Quartz.NET