set.rb 2.8 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071
  1. # Copyright (c) 2013 Douglas Thrift
  2. #
  3. # MIT License
  4. #
  5. # Permission is hereby granted, free of charge, to any person obtaining
  6. # a copy of this software and associated documentation files (the
  7. # "Software"), to deal in the Software without restriction, including
  8. # without limitation the rights to use, copy, modify, merge, publish,
  9. # distribute, sublicense, and/or sell copies of the Software, and to
  10. # permit persons to whom the Software is furnished to do so, subject to
  11. # the following conditions:
  12. #
  13. # The above copyright notice and this permission notice shall be
  14. # included in all copies or substantial portions of the Software.
  15. #
  16. # THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  17. # EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  18. # MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  19. # NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
  20. # LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
  21. # OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
  22. # WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  23. require 'set'
  24. module MachineTag
  25. # Set of tags which can be machine tags.
  26. #
  27. class Set < ::Set
  28. attr_reader :machine_tags
  29. def initialize(enum = nil, &block)
  30. @machine_tags = ::Set.new
  31. @tags_by_namespace = {}
  32. @tags_by_namespace_and_predicate = {}
  33. super
  34. end
  35. def add(tag)
  36. tag = Tag.new(tag) unless tag.is_a? Tag
  37. super(tag)
  38. if tag.machine_tag?
  39. @machine_tags << tag
  40. @tags_by_namespace[tag.namespace] ||= ::Set.new
  41. @tags_by_namespace[tag.namespace] << tag
  42. @tags_by_namespace_and_predicate[tag.namespace_and_predicate] ||= ::Set.new
  43. @tags_by_namespace_and_predicate[tag.namespace_and_predicate] << tag
  44. end
  45. end
  46. def [](namespace_or_namespace_and_predicate, predicate = nil)
  47. if namespace_or_namespace_and_predicate =~ /^#{PREFIX}$/
  48. namespace = namespace_or_namespace_and_predicate
  49. unless predicate
  50. @tags_by_namespace[namespace]
  51. else
  52. raise ArgumentError, "Invalid machine tag predicate: #{predicate.inspect}" unless predicate =~ /^#{PREFIX}$/
  53. @tags_by_namespace_and_predicate["#{namespace}:#{predicate}"]
  54. end
  55. elsif namespace_or_namespace_and_predicate =~ /^#{NAMESPACE_AND_PREDICATE}$/
  56. namespace_and_predicate = namespace_or_namespace_and_predicate
  57. raise ArgumentError, "Separate predicate passed with namespace and predicate: #{namespace_and_predicate.inspect}, #{predicate.inspect}" if predicate
  58. @tags_by_namespace_and_predicate[namespace_and_predicate]
  59. else
  60. raise ArgumentError, "Invalid machine tag namespace and/or predicate: #{namespace_or_namespace_and_predicate.inspect}, #{predicate.inspect}"
  61. end
  62. end
  63. end
  64. end