kkonganti@1: #!/usr/bin/env python
kkonganti@1: 
kkonganti@1: import yaml
kkonganti@1: import platform
kkonganti@1: import subprocess
kkonganti@1: from textwrap import dedent
kkonganti@1: 
kkonganti@1: 
kkonganti@1: def _make_versions_html(versions):
kkonganti@1:     html = [
kkonganti@1:         dedent(
kkonganti@1:             """\\
kkonganti@1:             <link rel="stylesheet" type="text/css" href="https://cdn.datatables.net/v/dt/jszip-2.5.0/dt-1.12.1/b-2.2.3/b-colvis-2.2.3/b-html5-2.2.3/b-print-2.2.3/fc-4.1.0/r-2.3.0/sc-2.0.6/sb-1.3.3/sp-2.0.1/datatables.min.css"/>
kkonganti@1:             <script type="text/javascript" src="https://cdnjs.cloudflare.com/ajax/libs/pdfmake/0.1.36/pdfmake.min.js"></script>
kkonganti@1:             <script type="text/javascript" src="https://cdnjs.cloudflare.com/ajax/libs/pdfmake/0.1.36/vfs_fonts.js"></script>
kkonganti@1:             <script type="text/javascript" src="https://cdn.datatables.net/v/dt/jszip-2.5.0/dt-1.12.1/b-2.2.3/b-colvis-2.2.3/b-html5-2.2.3/b-print-2.2.3/fc-4.1.0/r-2.3.0/sc-2.0.6/sb-1.3.3/sp-2.0.1/datatables.min.js"></script>
kkonganti@1:             <style>
kkonganti@1:             #cpipes-software-versions tbody:nth-child(even) {
kkonganti@1:                 background-color: #f2f2f2;
kkonganti@1:             }
kkonganti@1:             </style>
kkonganti@1:             <table class="table" style="width:100%" id="cpipes-software-versions">
kkonganti@1:                 <thead>
kkonganti@1:                     <tr>
kkonganti@1:                         <th> Process Name </th>
kkonganti@1:                         <th> Software </th>
kkonganti@1:                         <th> Version  </th>
kkonganti@1:                     </tr>
kkonganti@1:                 </thead>
kkonganti@1:             """
kkonganti@1:         )
kkonganti@1:     ]
kkonganti@1:     for process, tmp_versions in sorted(versions.items()):
kkonganti@1:         html.append("<tbody>")
kkonganti@1:         for i, (tool, version) in enumerate(sorted(tmp_versions.items())):
kkonganti@1:             html.append(
kkonganti@1:                 dedent(
kkonganti@1:                     f"""\\
kkonganti@1:                     <tr>
kkonganti@1:                         <td><samp>{process if (i == 0) else ''}</samp></td>
kkonganti@1:                         <td><samp>{tool}</samp></td>
kkonganti@1:                         <td><samp>{version}</samp></td>
kkonganti@1:                     </tr>
kkonganti@1:                     """
kkonganti@1:                 )
kkonganti@1:             )
kkonganti@1:         html.append("</tbody>")
kkonganti@1:     html.append("</table>")
kkonganti@1:     return "\\n".join(html)
kkonganti@1: 
kkonganti@1: 
kkonganti@1: versions_this_module = {}
kkonganti@1: versions_this_module["${task.process}"] = {
kkonganti@1:     "python": platform.python_version(),
kkonganti@1:     "yaml": yaml.__version__,
kkonganti@1: }
kkonganti@1: 
kkonganti@1: with open("$versions") as f:
kkonganti@1:     versions_by_process = yaml.load(f, Loader=yaml.BaseLoader)
kkonganti@1:     versions_by_process.update(versions_this_module)
kkonganti@1: 
kkonganti@1: # aggregate versions by the module name (derived from fully-qualified process name)
kkonganti@1: versions_by_module = {}
kkonganti@1: for process, process_versions in versions_by_process.items():
kkonganti@1:     module = process.split(":")[-1]
kkonganti@1:     try:
kkonganti@1:         assert versions_by_module[module] == process_versions, (
kkonganti@1:             "We assume that software versions are the same between all modules. "
kkonganti@1:             "If you see this error-message it means you discovered an edge-case "
kkonganti@1:             "and should open an issue in nf-core/tools. "
kkonganti@1:         )
kkonganti@1:     except KeyError:
kkonganti@1:         versions_by_module[module] = process_versions
kkonganti@1: 
kkonganti@1: versions_by_module["CPIPES"] = {
kkonganti@1:     "Nextflow": "$workflow.nextflow.version",
kkonganti@1:     "$workflow.manifest.name": "$workflow.manifest.version",
kkonganti@1:     "${params.pipeline}": "${params.workflow_version}",
kkonganti@1: }
kkonganti@1: 
kkonganti@1: versions_mqc = {
kkonganti@1:     "id": "software_versions",
kkonganti@1:     "section_name": "${workflow.manifest.name} Software Versions",
kkonganti@1:     "section_href": "https://github.com/CFSAN-Biostatistics/bettercallsal",
kkonganti@1:     "plot_type": "html",
kkonganti@1:     "description": "Collected at run time from the software output (STDOUT/STDERR).",
kkonganti@1:     "data": _make_versions_html(versions_by_module),
kkonganti@1: }
kkonganti@1: 
kkonganti@1: with open("software_versions.yml", "w") as f:
kkonganti@1:     yaml.dump(versions_by_module, f, default_flow_style=False)
kkonganti@1: 
kkonganti@1: # print('sed -i -e "' + "s%'%%g" + '" *.yml')
kkonganti@1: subprocess.run('sed -i -e "' + "s%'%%g" + '" software_versions.yml', shell=True)
kkonganti@1: 
kkonganti@1: with open("software_versions_mqc.yml", "w") as f:
kkonganti@1:     yaml.dump(versions_mqc, f, default_flow_style=False)
kkonganti@1: 
kkonganti@1: with open("versions.yml", "w") as f:
kkonganti@1:     yaml.dump(versions_this_module, f, default_flow_style=False)