Skip to content
Permalink

Comparing changes

Choose two branches to see what’s changed or to start a new pull request. If you need to, you can also or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: flowintel/cocktailparty
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: v0.2.0
Choose a base ref
...
head repository: flowintel/cocktailparty
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: main
Choose a head ref

Commits on Feb 5, 2024

  1. chg: [git] add gitchanglogrc

    adulau committed Feb 5, 2024
    Copy the full SHA
    9e8e868 View commit details

Commits on Jun 4, 2024

  1. Copy the full SHA
    b58785c View commit details

Commits on Jun 21, 2024

  1. Copy the full SHA
    6dae3e8 View commit details
  2. Copy the full SHA
    27424e5 View commit details

Commits on Jul 5, 2024

  1. Copy the full SHA
    77faf65 View commit details

Commits on Jul 9, 2024

  1. chg: [refacto] fix tests

    gallypette committed Jul 9, 2024
    Copy the full SHA
    d590d98 View commit details

Commits on Sep 13, 2024

  1. Copy the full SHA
    e9ad14a View commit details

Commits on Sep 27, 2024

  1. Copy the full SHA
    548892e View commit details

Commits on Sep 30, 2024

  1. Copy the full SHA
    11e7891 View commit details

Commits on Oct 1, 2024

  1. Copy the full SHA
    da76674 View commit details

Commits on Oct 4, 2024

  1. chg: [stomp] reconnection

    gallypette committed Oct 4, 2024
    Copy the full SHA
    6f9a1e6 View commit details
  2. Copy the full SHA
    5bf58b6 View commit details

Commits on Oct 7, 2024

  1. Copy the full SHA
    71ed119 View commit details
  2. Copy the full SHA
    c54feff View commit details

Commits on Oct 9, 2024

  1. Copy the full SHA
    0de657c View commit details

Commits on Oct 11, 2024

  1. Copy the full SHA
    7545012 View commit details
  2. Copy the full SHA
    877cfea View commit details

Commits on Oct 14, 2024

  1. Copy the full SHA
    e65d8c1 View commit details
  2. Copy the full SHA
    c1a9c05 View commit details
  3. Copy the full SHA
    af5a222 View commit details

Commits on Oct 15, 2024

  1. Copy the full SHA
    3e8f419 View commit details
  2. Copy the full SHA
    9cf7d18 View commit details
  3. Copy the full SHA
    c0a4d65 View commit details
  4. Copy the full SHA
    54e525d View commit details

Commits on Oct 18, 2024

  1. Copy the full SHA
    215a167 View commit details
  2. Copy the full SHA
    07ac533 View commit details
  3. chg: [chores] bumps

    gallypette committed Oct 18, 2024
    Copy the full SHA
    37e3b42 View commit details
  4. Copy the full SHA
    1376df1 View commit details

Commits on Oct 21, 2024

  1. Copy the full SHA
    bae9ffe View commit details

Commits on Oct 28, 2024

  1. Copy the full SHA
    0a66caa View commit details

Commits on Nov 15, 2024

  1. chg: [sinks] wip

    gallypette committed Nov 15, 2024
    Copy the full SHA
    bc434ad View commit details

Commits on Nov 29, 2024

  1. chg: [sinks] wip

    gallypette committed Nov 29, 2024
    Copy the full SHA
    31b96f0 View commit details

Commits on Jan 10, 2025

  1. Copy the full SHA
    838f91b View commit details
  2. Copy the full SHA
    a182dfc View commit details
  3. Copy the full SHA
    78e61cb View commit details
  4. Copy the full SHA
    8214aed View commit details
  5. Copy the full SHA
    93c40f7 View commit details

Commits on Jan 13, 2025

  1. Copy the full SHA
    1421126 View commit details

Commits on Jan 14, 2025

  1. Copy the full SHA
    bfe2640 View commit details
  2. bump: [js]

    gallypette committed Jan 14, 2025
    Copy the full SHA
    2813551 View commit details
  3. Copy the full SHA
    1561808 View commit details
  4. chg: [doc] adds logo

    gallypette authored Jan 14, 2025
    Copy the full SHA
    2acf93c View commit details

Commits on Jan 16, 2025

  1. Copy the full SHA
    688a294 View commit details

Commits on Jan 17, 2025

  1. Copy the full SHA
    d85e971 View commit details

Commits on Jan 20, 2025

  1. Copy the full SHA
    1ed77f1 View commit details

Commits on Jan 21, 2025

  1. Copy the full SHA
    37c596c View commit details

Commits on Jan 23, 2025

  1. Copy the full SHA
    ae9ecec View commit details

Commits on Jan 24, 2025

  1. Copy the full SHA
    699794c View commit details
  2. Copy the full SHA
    805e13f View commit details
Showing with 3,841 additions and 2,495 deletions.
  1. +289 −0 .gitchangelog.rc
  2. +4 −1 README.md
  3. +70 −1,399 assets/package-lock.json
  4. +1 −1 assets/package.json
  5. +2 −0 config/config.exs
  6. +2 −0 lib/cocktailparty/application.ex
  7. +0 −211 lib/cocktailparty/broker.ex
  8. +111 −46 lib/cocktailparty/catalog.ex
  9. +88 −0 lib/cocktailparty/catalog/dummy_websocket.ex
  10. +53 −0 lib/cocktailparty/catalog/redis_LPOP.ex
  11. +81 −0 lib/cocktailparty/catalog/redis_channel.ex
  12. +61 −5 lib/cocktailparty/catalog/source.ex
  13. +17 −0 lib/cocktailparty/catalog/source_behaviour.ex
  14. +90 −0 lib/cocktailparty/catalog/source_manager.ex
  15. +70 −0 lib/cocktailparty/catalog/source_type.ex
  16. +83 −0 lib/cocktailparty/catalog/stomp_subscribe.ex
  17. +17 −0 lib/cocktailparty/connections_dynamic_supervisor.ex
  18. +20 −9 lib/cocktailparty/dynamic_supervisor_boot.ex
  19. +3 −0 lib/cocktailparty/encrypted_map.ex
  20. +214 −65 lib/cocktailparty/input.ex
  21. +95 −0 lib/cocktailparty/input/connection.ex
  22. +3 −0 lib/cocktailparty/input/connection_behaviour.ex
  23. +15 −0 lib/cocktailparty/input/connection_manager.ex
  24. +106 −0 lib/cocktailparty/input/connection_type.ex
  25. +27 −0 lib/cocktailparty/input/phoenix.ex
  26. +149 −0 lib/cocktailparty/input/phoenix_client.ex
  27. +26 −0 lib/cocktailparty/input/redis.ex
  28. +0 −156 lib/cocktailparty/input/redis_instance.ex
  29. +31 −0 lib/cocktailparty/input/redis_pub_sub.ex
  30. +32 −0 lib/cocktailparty/input/stomp.ex
  31. +332 −0 lib/cocktailparty/input/stomp_pub_sub.ex
  32. +32 −0 lib/cocktailparty/input/websocket.ex
  33. +83 −0 lib/cocktailparty/input/websocket_client.ex
  34. +58 −31 lib/cocktailparty/sink_catalog.ex
  35. +73 −0 lib/cocktailparty/sink_catalog/redis_channel_sink.ex
  36. +62 −5 lib/cocktailparty/sink_catalog/sink.ex
  37. +19 −0 lib/cocktailparty/sink_catalog/sink_behaviour.ex
  38. +90 −0 lib/cocktailparty/sink_catalog/sink_manager.ex
  39. +45 −0 lib/cocktailparty/sink_catalog/sink_type.ex
  40. +2 −2 lib/cocktailparty/{redis_instances_dynamic_supervisor.ex → sinks_dynamic_supervisor.ex}
  41. +21 −0 lib/cocktailparty/sources_dynamic_supervisor.ex
  42. +18 −0 lib/cocktailparty/vault.ex
  43. +1 −1 lib/cocktailparty_web.ex
  44. +3 −1 lib/cocktailparty_web/access_control.ex
  45. +12 −5 lib/cocktailparty_web/channels/feed_channel.ex
  46. +9 −14 lib/cocktailparty_web/channels/sink_channel.ex
  47. +1 −1 lib/cocktailparty_web/components/core_components.ex
  48. +3 −3 lib/cocktailparty_web/components/layouts/root.html.heex
  49. +139 −0 lib/cocktailparty_web/controllers/admin/connection_controller.ex
  50. +14 −0 lib/cocktailparty_web/controllers/admin/connection_html.ex
  51. +28 −0 lib/cocktailparty_web/controllers/admin/connection_html/connection_edit_form.html.heex
  52. +63 −0 lib/cocktailparty_web/controllers/admin/connection_html/connection_form.html.heex
  53. +12 −0 lib/cocktailparty_web/controllers/admin/connection_html/edit.html.heex
  54. +50 −0 lib/cocktailparty_web/controllers/admin/connection_html/index.html.heex
  55. +8 −0 lib/cocktailparty_web/controllers/admin/connection_html/new.html.heex
  56. +61 −0 lib/cocktailparty_web/controllers/admin/connection_html/show.html.heex
  57. +0 −66 lib/cocktailparty_web/controllers/admin/redis_instance_controller.ex
  58. +0 −13 lib/cocktailparty_web/controllers/admin/redis_instance_html.ex
  59. +0 −11 lib/cocktailparty_web/controllers/admin/redis_instance_html/edit.html.heex
  60. +0 −49 lib/cocktailparty_web/controllers/admin/redis_instance_html/index.html.heex
  61. +0 −8 lib/cocktailparty_web/controllers/admin/redis_instance_html/new.html.heex
  62. +0 −13 lib/cocktailparty_web/controllers/admin/redis_instance_html/redis_instance_form.html.heex
  63. +0 −33 lib/cocktailparty_web/controllers/admin/redis_instance_html/show.html.heex
  64. +95 −19 lib/cocktailparty_web/controllers/admin/sink_controller.ex
  65. +3 −1 lib/cocktailparty_web/controllers/admin/sink_html.ex
  66. +3 −1 lib/cocktailparty_web/controllers/admin/sink_html/edit.html.heex
  67. +2 −4 lib/cocktailparty_web/controllers/admin/sink_html/index.html.heex
  68. +3 −1 lib/cocktailparty_web/controllers/admin/sink_html/new.html.heex
  69. +1 −2 lib/cocktailparty_web/controllers/admin/sink_html/show.html.heex
  70. +85 −7 lib/cocktailparty_web/controllers/admin/sink_html/sink_form.html.heex
  71. +117 −18 lib/cocktailparty_web/controllers/admin/source_controller.ex
  72. +3 −1 lib/cocktailparty_web/controllers/admin/source_html.ex
  73. +1 −86 lib/cocktailparty_web/controllers/sink_controller.ex
  74. +0 −13 lib/cocktailparty_web/controllers/sink_html.ex
  75. +0 −8 lib/cocktailparty_web/controllers/sink_html/edit.html.heex
  76. +0 −8 lib/cocktailparty_web/controllers/sink_html/new.html.heex
  77. +0 −12 lib/cocktailparty_web/controllers/sink_html/sink_form.html.heex
  78. +1 −1 lib/cocktailparty_web/controllers/source_controller.ex
  79. +3 −1 lib/cocktailparty_web/controllers/source_html.ex
  80. +3 −1 lib/cocktailparty_web/controllers/source_html/edit.html.heex
  81. +2 −6 lib/cocktailparty_web/controllers/source_html/index.html.heex
  82. +19 −1 lib/cocktailparty_web/controllers/source_html/new.html.heex
  83. +26 −3 lib/cocktailparty_web/controllers/source_html/show.html.heex
  84. +86 −7 lib/cocktailparty_web/controllers/source_html/source_form.html.heex
  85. +1 −1 lib/cocktailparty_web/gettext.ex
  86. +3 −2 lib/cocktailparty_web/router.ex
  87. +61 −0 lib/util.ex
  88. +14 −6 mix.exs
  89. +44 −38 mix.lock
  90. +30 −0 priv/repo/migrations/20240530090322_redis_decoupling.exs
  91. +10 −0 priv/repo/migrations/20240621075140_redis_decoupling_indexes.exs
  92. +16 −0 priv/repo/migrations/20241015065046_add_encrypted_config.exs
  93. +141 −0 test/cocktailparty_web/controllers/connection_controller_test.exs
  94. +0 −87 test/cocktailparty_web/controllers/redis_instance_controller_test.exs
  95. +15 −0 test/support/conn_case.ex
  96. +13 −11 test/support/fixtures/input_fixtures.ex
  97. +21 −0 test/support/fixtures/roles_fixtures.ex
  98. +20 −0 test/support/fixtures/user_management_fixtures.ex
289 changes: 289 additions & 0 deletions .gitchangelog.rc
Original file line number Diff line number Diff line change
@@ -0,0 +1,289 @@
# -*- coding: utf-8; mode: python -*-
##
## Format
##
## ACTION: [AUDIENCE:] COMMIT_MSG [!TAG ...]
##
## Description
##
## ACTION is one of 'chg', 'fix', 'new'
##
## Is WHAT the change is about.
##
## 'chg' is for refactor, small improvement, cosmetic changes...
## 'fix' is for bug fixes
## 'new' is for new features, big improvement
##
## AUDIENCE is optional and one of 'dev', 'usr', 'pkg', 'test', 'doc'|'docs'
##
## Is WHO is concerned by the change.
##
## 'dev' is for developpers (API changes, refactors...)
## 'usr' is for final users (UI changes)
## 'pkg' is for packagers (packaging changes)
## 'test' is for testers (test only related changes)
## 'doc' is for doc guys (doc only changes)
##
## COMMIT_MSG is ... well ... the commit message itself.
##
## TAGs are additionnal adjective as 'refactor' 'minor' 'cosmetic'
##
## They are preceded with a '!' or a '@' (prefer the former, as the
## latter is wrongly interpreted in github.) Commonly used tags are:
##
## 'refactor' is obviously for refactoring code only
## 'minor' is for a very meaningless change (a typo, adding a comment)
## 'cosmetic' is for cosmetic driven change (re-indentation, 80-col...)
## 'wip' is for partial functionality but complete subfunctionality.
##
## Example:
##
## new: usr: support of bazaar implemented
## chg: re-indentend some lines !cosmetic
## new: dev: updated code to be compatible with last version of killer lib.
## fix: pkg: updated year of licence coverage.
## new: test: added a bunch of test around user usability of feature X.
## fix: typo in spelling my name in comment. !minor
##
## Please note that multi-line commit message are supported, and only the
## first line will be considered as the "summary" of the commit message. So
## tags, and other rules only applies to the summary. The body of the commit
## message will be displayed in the changelog without reformatting.


##
## ``ignore_regexps`` is a line of regexps
##
## Any commit having its full commit message matching any regexp listed here
## will be ignored and won't be reported in the changelog.
##
ignore_regexps = [
r'@minor', r'!minor',
r'@cosmetic', r'!cosmetic',
r'@refactor', r'!refactor',
r'@wip', r'!wip',
r'^([cC]hg|[fF]ix|[nN]ew)\s*:\s*[p|P]kg:',
r'^([cC]hg|[fF]ix|[nN]ew)\s*:\s*[d|D]ev:',
r'^(.{3,3}\s*:)?\s*[fF]irst commit.?\s*$',
]


## ``section_regexps`` is a list of 2-tuples associating a string label and a
## list of regexp
##
## Commit messages will be classified in sections thanks to this. Section
## titles are the label, and a commit is classified under this section if any
## of the regexps associated is matching.
##
## Please note that ``section_regexps`` will only classify commits and won't
## make any changes to the contents. So you'll probably want to go check
## ``subject_process`` (or ``body_process``) to do some changes to the subject,
## whenever you are tweaking this variable.
##
section_regexps = [
('New', [
r'^[nN]ew\s*:\s*((dev|use?r|pkg|test|doc|docs)\s*:\s*)?([^\n]*)$',
]),
('Changes', [
r'^[cC]hg\s*:\s*((dev|use?r|pkg|test|doc|docs)\s*:\s*)?([^\n]*)$',
]),
('Fix', [
r'^[fF]ix\s*:\s*((dev|use?r|pkg|test|doc|docs)\s*:\s*)?([^\n]*)$',
]),

('Other', None ## Match all lines
),

]


## ``body_process`` is a callable
##
## This callable will be given the original body and result will
## be used in the changelog.
##
## Available constructs are:
##
## - any python callable that take one txt argument and return txt argument.
##
## - ReSub(pattern, replacement): will apply regexp substitution.
##
## - Indent(chars=" "): will indent the text with the prefix
## Please remember that template engines gets also to modify the text and
## will usually indent themselves the text if needed.
##
## - Wrap(regexp=r"\n\n"): re-wrap text in separate paragraph to fill 80-Columns
##
## - noop: do nothing
##
## - ucfirst: ensure the first letter is uppercase.
## (usually used in the ``subject_process`` pipeline)
##
## - final_dot: ensure text finishes with a dot
## (usually used in the ``subject_process`` pipeline)
##
## - strip: remove any spaces before or after the content of the string
##
## - SetIfEmpty(msg="No commit message."): will set the text to
## whatever given ``msg`` if the current text is empty.
##
## Additionally, you can `pipe` the provided filters, for instance:
#body_process = Wrap(regexp=r'\n(?=\w+\s*:)') | Indent(chars=" ")
#body_process = Wrap(regexp=r'\n(?=\w+\s*:)')
#body_process = noop
body_process = ReSub(r'((^|\n)[A-Z]\w+(-\w+)*: .*(\n\s+.*)*)+$', r'') | strip


## ``subject_process`` is a callable
##
## This callable will be given the original subject and result will
## be used in the changelog.
##
## Available constructs are those listed in ``body_process`` doc.
subject_process = (strip |
ReSub(r'^([cC]hg|[fF]ix|[nN]ew)\s*:\s*((dev|use?r|pkg|test|doc|docs)\s*:\s*)?([^\n@]*)(@[a-z]+\s+)*$', r'\4') |
SetIfEmpty("No commit message.") | ucfirst | final_dot)


## ``tag_filter_regexp`` is a regexp
##
## Tags that will be used for the changelog must match this regexp.
##
tag_filter_regexp = r'^v[0-9]+\.[0-9]+\.[0-9]+$'



## ``unreleased_version_label`` is a string or a callable that outputs a string
##
## This label will be used as the changelog Title of the last set of changes
## between last valid tag and HEAD if any.
unreleased_version_label = "%%version%% (unreleased)"


## ``output_engine`` is a callable
##
## This will change the output format of the generated changelog file
##
## Available choices are:
##
## - rest_py
##
## Legacy pure python engine, outputs ReSTructured text.
## This is the default.
##
## - mustache(<template_name>)
##
## Template name could be any of the available templates in
## ``templates/mustache/*.tpl``.
## Requires python package ``pystache``.
## Examples:
## - mustache("markdown")
## - mustache("restructuredtext")
##
## - makotemplate(<template_name>)
##
## Template name could be any of the available templates in
## ``templates/mako/*.tpl``.
## Requires python package ``mako``.
## Examples:
## - makotemplate("restructuredtext")
##
output_engine = rest_py
#output_engine = mustache("restructuredtext")
#output_engine = mustache("markdown")
#output_engine = makotemplate("restructuredtext")


## ``include_merge`` is a boolean
##
## This option tells git-log whether to include merge commits in the log.
## The default is to include them.
include_merge = True


## ``log_encoding`` is a string identifier
##
## This option tells gitchangelog what encoding is outputed by ``git log``.
## The default is to be clever about it: it checks ``git config`` for
## ``i18n.logOutputEncoding``, and if not found will default to git's own
## default: ``utf-8``.
#log_encoding = 'utf-8'


## ``publish`` is a callable
##
## Sets what ``gitchangelog`` should do with the output generated by
## the output engine. ``publish`` is a callable taking one argument
## that is an interator on lines from the output engine.
##
## Some helper callable are provided:
##
## Available choices are:
##
## - stdout
##
## Outputs directly to standard output
## (This is the default)
##
## - FileInsertAtFirstRegexMatch(file, pattern, idx=lamda m: m.start())
##
## Creates a callable that will parse given file for the given
## regex pattern and will insert the output in the file.
## ``idx`` is a callable that receive the matching object and
## must return a integer index point where to insert the
## the output in the file. Default is to return the position of
## the start of the matched string.
##
## - FileRegexSubst(file, pattern, replace, flags)
##
## Apply a replace inplace in the given file. Your regex pattern must
## take care of everything and might be more complex. Check the README
## for a complete copy-pastable example.
##
# publish = FileInsertIntoFirstRegexMatch(
# "CHANGELOG.rst",
# r'/(?P<rev>[0-9]+\.[0-9]+(\.[0-9]+)?)\s+\([0-9]+-[0-9]{2}-[0-9]{2}\)\n--+\n/',
# idx=lambda m: m.start(1)
# )
#publish = stdout


## ``revs`` is a list of callable or a list of string
##
## callable will be called to resolve as strings and allow dynamical
## computation of these. The result will be used as revisions for
## gitchangelog (as if directly stated on the command line). This allows
## to filter exaclty which commits will be read by gitchangelog.
##
## To get a full documentation on the format of these strings, please
## refer to the ``git rev-list`` arguments. There are many examples.
##
## Using callables is especially useful, for instance, if you
## are using gitchangelog to generate incrementally your changelog.
##
## Some helpers are provided, you can use them::
##
## - FileFirstRegexMatch(file, pattern): will return a callable that will
## return the first string match for the given pattern in the given file.
## If you use named sub-patterns in your regex pattern, it'll output only
## the string matching the regex pattern named "rev".
##
## - Caret(rev): will return the rev prefixed by a "^", which is a
## way to remove the given revision and all its ancestor.
##
## Please note that if you provide a rev-list on the command line, it'll
## replace this value (which will then be ignored).
##
## If empty, then ``gitchangelog`` will act as it had to generate a full
## changelog.
##
## The default is to use all commits to make the changelog.
#revs = ["^1.0.3", ]
#revs = [
# Caret(
# FileFirstRegexMatch(
# "CHANGELOG.rst",
# r"(?P<rev>[0-9]+\.[0-9]+(\.[0-9]+)?)\s+\([0-9]+-[0-9]{2}-[0-9]{2}\)\n--+\n")),
# "HEAD"
#]
revs = []
5 changes: 4 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
# CocktailParty

![logo-cocktail-party-horizontal-coul](https://github.com/user-attachments/assets/bc59b4be-d3f0-4fda-bb73-fe9a7487f9d2)

This project is a work in progress and not feature complete, therefore this readme may not align with reality.

@@ -30,6 +31,8 @@ git clone https://github.com/flowintel/cocktailparty.git
cd cocktailparty
mix deps.get
mix compile
cd assets
npm install
mix phx.server
```

Loading