diff --git a/.gitignore b/.gitignore
index 96ef6c0..1a1541a 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,2 +1,40 @@
/target
Cargo.lock
+
+# Created by https://www.toptal.com/developers/gitignore/api/macos
+# Edit at https://www.toptal.com/developers/gitignore?templates=macos
+
+### macOS ###
+# General
+.DS_Store
+.AppleDouble
+.LSOverride
+
+# Icon must end with two \r
+Icon
+
+
+# Thumbnails
+._*
+
+# Files that might appear in the root of a volume
+.DocumentRevisions-V100
+.fseventsd
+.Spotlight-V100
+.TemporaryItems
+.Trashes
+.VolumeIcon.icns
+.com.apple.timemachine.donotpresent
+
+# Directories potentially created on remote AFP share
+.AppleDB
+.AppleDesktop
+Network Trash Folder
+Temporary Items
+.apdisk
+
+### macOS Patch ###
+# iCloud generated files
+*.icloud
+
+# End of https://www.toptal.com/developers/gitignore/api/macos
diff --git a/Cargo.toml b/Cargo.toml
index 494728b..0b4dd2c 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -1,10 +1,16 @@
[package]
-name = "VCDViewer"
+name = "fastwave_backend"
version = "0.1.0"
edition = "2021"
+[profile.release]
+debug = 1
+
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
[dependencies]
num = "0.4"
-clap = { version = "3.1.8", features = ["derive"] }
+clap = { version = "4.4.6", features = ["derive"] }
+chrono = "0.4"
+# TODO : remove itertools once date parser is reworked.
+itertools = "0.11"
diff --git a/LICENSE-GPLV3 b/LICENSE-GPLV3
new file mode 100644
index 0000000..f288702
--- /dev/null
+++ b/LICENSE-GPLV3
@@ -0,0 +1,674 @@
+ GNU GENERAL PUBLIC LICENSE
+ Version 3, 29 June 2007
+
+ Copyright (C) 2007 Free Software Foundation, Inc.
+ Everyone is permitted to copy and distribute verbatim copies
+ of this license document, but changing it is not allowed.
+
+ Preamble
+
+ The GNU General Public License is a free, copyleft license for
+software and other kinds of works.
+
+ The licenses for most software and other practical works are designed
+to take away your freedom to share and change the works. By contrast,
+the GNU General Public License is intended to guarantee your freedom to
+share and change all versions of a program--to make sure it remains free
+software for all its users. We, the Free Software Foundation, use the
+GNU General Public License for most of our software; it applies also to
+any other work released this way by its authors. You can apply it to
+your programs, too.
+
+ When we speak of free software, we are referring to freedom, not
+price. Our General Public Licenses are designed to make sure that you
+have the freedom to distribute copies of free software (and charge for
+them if you wish), that you receive source code or can get it if you
+want it, that you can change the software or use pieces of it in new
+free programs, and that you know you can do these things.
+
+ To protect your rights, we need to prevent others from denying you
+these rights or asking you to surrender the rights. Therefore, you have
+certain responsibilities if you distribute copies of the software, or if
+you modify it: responsibilities to respect the freedom of others.
+
+ For example, if you distribute copies of such a program, whether
+gratis or for a fee, you must pass on to the recipients the same
+freedoms that you received. You must make sure that they, too, receive
+or can get the source code. And you must show them these terms so they
+know their rights.
+
+ Developers that use the GNU GPL protect your rights with two steps:
+(1) assert copyright on the software, and (2) offer you this License
+giving you legal permission to copy, distribute and/or modify it.
+
+ For the developers' and authors' protection, the GPL clearly explains
+that there is no warranty for this free software. For both users' and
+authors' sake, the GPL requires that modified versions be marked as
+changed, so that their problems will not be attributed erroneously to
+authors of previous versions.
+
+ Some devices are designed to deny users access to install or run
+modified versions of the software inside them, although the manufacturer
+can do so. This is fundamentally incompatible with the aim of
+protecting users' freedom to change the software. The systematic
+pattern of such abuse occurs in the area of products for individuals to
+use, which is precisely where it is most unacceptable. Therefore, we
+have designed this version of the GPL to prohibit the practice for those
+products. If such problems arise substantially in other domains, we
+stand ready to extend this provision to those domains in future versions
+of the GPL, as needed to protect the freedom of users.
+
+ Finally, every program is threatened constantly by software patents.
+States should not allow patents to restrict development and use of
+software on general-purpose computers, but in those that do, we wish to
+avoid the special danger that patents applied to a free program could
+make it effectively proprietary. To prevent this, the GPL assures that
+patents cannot be used to render the program non-free.
+
+ The precise terms and conditions for copying, distribution and
+modification follow.
+
+ TERMS AND CONDITIONS
+
+ 0. Definitions.
+
+ "This License" refers to version 3 of the GNU General Public License.
+
+ "Copyright" also means copyright-like laws that apply to other kinds of
+works, such as semiconductor masks.
+
+ "The Program" refers to any copyrightable work licensed under this
+License. Each licensee is addressed as "you". "Licensees" and
+"recipients" may be individuals or organizations.
+
+ To "modify" a work means to copy from or adapt all or part of the work
+in a fashion requiring copyright permission, other than the making of an
+exact copy. The resulting work is called a "modified version" of the
+earlier work or a work "based on" the earlier work.
+
+ A "covered work" means either the unmodified Program or a work based
+on the Program.
+
+ To "propagate" a work means to do anything with it that, without
+permission, would make you directly or secondarily liable for
+infringement under applicable copyright law, except executing it on a
+computer or modifying a private copy. Propagation includes copying,
+distribution (with or without modification), making available to the
+public, and in some countries other activities as well.
+
+ To "convey" a work means any kind of propagation that enables other
+parties to make or receive copies. Mere interaction with a user through
+a computer network, with no transfer of a copy, is not conveying.
+
+ An interactive user interface displays "Appropriate Legal Notices"
+to the extent that it includes a convenient and prominently visible
+feature that (1) displays an appropriate copyright notice, and (2)
+tells the user that there is no warranty for the work (except to the
+extent that warranties are provided), that licensees may convey the
+work under this License, and how to view a copy of this License. If
+the interface presents a list of user commands or options, such as a
+menu, a prominent item in the list meets this criterion.
+
+ 1. Source Code.
+
+ The "source code" for a work means the preferred form of the work
+for making modifications to it. "Object code" means any non-source
+form of a work.
+
+ A "Standard Interface" means an interface that either is an official
+standard defined by a recognized standards body, or, in the case of
+interfaces specified for a particular programming language, one that
+is widely used among developers working in that language.
+
+ The "System Libraries" of an executable work include anything, other
+than the work as a whole, that (a) is included in the normal form of
+packaging a Major Component, but which is not part of that Major
+Component, and (b) serves only to enable use of the work with that
+Major Component, or to implement a Standard Interface for which an
+implementation is available to the public in source code form. A
+"Major Component", in this context, means a major essential component
+(kernel, window system, and so on) of the specific operating system
+(if any) on which the executable work runs, or a compiler used to
+produce the work, or an object code interpreter used to run it.
+
+ The "Corresponding Source" for a work in object code form means all
+the source code needed to generate, install, and (for an executable
+work) run the object code and to modify the work, including scripts to
+control those activities. However, it does not include the work's
+System Libraries, or general-purpose tools or generally available free
+programs which are used unmodified in performing those activities but
+which are not part of the work. For example, Corresponding Source
+includes interface definition files associated with source files for
+the work, and the source code for shared libraries and dynamically
+linked subprograms that the work is specifically designed to require,
+such as by intimate data communication or control flow between those
+subprograms and other parts of the work.
+
+ The Corresponding Source need not include anything that users
+can regenerate automatically from other parts of the Corresponding
+Source.
+
+ The Corresponding Source for a work in source code form is that
+same work.
+
+ 2. Basic Permissions.
+
+ All rights granted under this License are granted for the term of
+copyright on the Program, and are irrevocable provided the stated
+conditions are met. This License explicitly affirms your unlimited
+permission to run the unmodified Program. The output from running a
+covered work is covered by this License only if the output, given its
+content, constitutes a covered work. This License acknowledges your
+rights of fair use or other equivalent, as provided by copyright law.
+
+ You may make, run and propagate covered works that you do not
+convey, without conditions so long as your license otherwise remains
+in force. You may convey covered works to others for the sole purpose
+of having them make modifications exclusively for you, or provide you
+with facilities for running those works, provided that you comply with
+the terms of this License in conveying all material for which you do
+not control copyright. Those thus making or running the covered works
+for you must do so exclusively on your behalf, under your direction
+and control, on terms that prohibit them from making any copies of
+your copyrighted material outside their relationship with you.
+
+ Conveying under any other circumstances is permitted solely under
+the conditions stated below. Sublicensing is not allowed; section 10
+makes it unnecessary.
+
+ 3. Protecting Users' Legal Rights From Anti-Circumvention Law.
+
+ No covered work shall be deemed part of an effective technological
+measure under any applicable law fulfilling obligations under article
+11 of the WIPO copyright treaty adopted on 20 December 1996, or
+similar laws prohibiting or restricting circumvention of such
+measures.
+
+ When you convey a covered work, you waive any legal power to forbid
+circumvention of technological measures to the extent such circumvention
+is effected by exercising rights under this License with respect to
+the covered work, and you disclaim any intention to limit operation or
+modification of the work as a means of enforcing, against the work's
+users, your or third parties' legal rights to forbid circumvention of
+technological measures.
+
+ 4. Conveying Verbatim Copies.
+
+ You may convey verbatim copies of the Program's source code as you
+receive it, in any medium, provided that you conspicuously and
+appropriately publish on each copy an appropriate copyright notice;
+keep intact all notices stating that this License and any
+non-permissive terms added in accord with section 7 apply to the code;
+keep intact all notices of the absence of any warranty; and give all
+recipients a copy of this License along with the Program.
+
+ You may charge any price or no price for each copy that you convey,
+and you may offer support or warranty protection for a fee.
+
+ 5. Conveying Modified Source Versions.
+
+ You may convey a work based on the Program, or the modifications to
+produce it from the Program, in the form of source code under the
+terms of section 4, provided that you also meet all of these conditions:
+
+ a) The work must carry prominent notices stating that you modified
+ it, and giving a relevant date.
+
+ b) The work must carry prominent notices stating that it is
+ released under this License and any conditions added under section
+ 7. This requirement modifies the requirement in section 4 to
+ "keep intact all notices".
+
+ c) You must license the entire work, as a whole, under this
+ License to anyone who comes into possession of a copy. This
+ License will therefore apply, along with any applicable section 7
+ additional terms, to the whole of the work, and all its parts,
+ regardless of how they are packaged. This License gives no
+ permission to license the work in any other way, but it does not
+ invalidate such permission if you have separately received it.
+
+ d) If the work has interactive user interfaces, each must display
+ Appropriate Legal Notices; however, if the Program has interactive
+ interfaces that do not display Appropriate Legal Notices, your
+ work need not make them do so.
+
+ A compilation of a covered work with other separate and independent
+works, which are not by their nature extensions of the covered work,
+and which are not combined with it such as to form a larger program,
+in or on a volume of a storage or distribution medium, is called an
+"aggregate" if the compilation and its resulting copyright are not
+used to limit the access or legal rights of the compilation's users
+beyond what the individual works permit. Inclusion of a covered work
+in an aggregate does not cause this License to apply to the other
+parts of the aggregate.
+
+ 6. Conveying Non-Source Forms.
+
+ You may convey a covered work in object code form under the terms
+of sections 4 and 5, provided that you also convey the
+machine-readable Corresponding Source under the terms of this License,
+in one of these ways:
+
+ a) Convey the object code in, or embodied in, a physical product
+ (including a physical distribution medium), accompanied by the
+ Corresponding Source fixed on a durable physical medium
+ customarily used for software interchange.
+
+ b) Convey the object code in, or embodied in, a physical product
+ (including a physical distribution medium), accompanied by a
+ written offer, valid for at least three years and valid for as
+ long as you offer spare parts or customer support for that product
+ model, to give anyone who possesses the object code either (1) a
+ copy of the Corresponding Source for all the software in the
+ product that is covered by this License, on a durable physical
+ medium customarily used for software interchange, for a price no
+ more than your reasonable cost of physically performing this
+ conveying of source, or (2) access to copy the
+ Corresponding Source from a network server at no charge.
+
+ c) Convey individual copies of the object code with a copy of the
+ written offer to provide the Corresponding Source. This
+ alternative is allowed only occasionally and noncommercially, and
+ only if you received the object code with such an offer, in accord
+ with subsection 6b.
+
+ d) Convey the object code by offering access from a designated
+ place (gratis or for a charge), and offer equivalent access to the
+ Corresponding Source in the same way through the same place at no
+ further charge. You need not require recipients to copy the
+ Corresponding Source along with the object code. If the place to
+ copy the object code is a network server, the Corresponding Source
+ may be on a different server (operated by you or a third party)
+ that supports equivalent copying facilities, provided you maintain
+ clear directions next to the object code saying where to find the
+ Corresponding Source. Regardless of what server hosts the
+ Corresponding Source, you remain obligated to ensure that it is
+ available for as long as needed to satisfy these requirements.
+
+ e) Convey the object code using peer-to-peer transmission, provided
+ you inform other peers where the object code and Corresponding
+ Source of the work are being offered to the general public at no
+ charge under subsection 6d.
+
+ A separable portion of the object code, whose source code is excluded
+from the Corresponding Source as a System Library, need not be
+included in conveying the object code work.
+
+ A "User Product" is either (1) a "consumer product", which means any
+tangible personal property which is normally used for personal, family,
+or household purposes, or (2) anything designed or sold for incorporation
+into a dwelling. In determining whether a product is a consumer product,
+doubtful cases shall be resolved in favor of coverage. For a particular
+product received by a particular user, "normally used" refers to a
+typical or common use of that class of product, regardless of the status
+of the particular user or of the way in which the particular user
+actually uses, or expects or is expected to use, the product. A product
+is a consumer product regardless of whether the product has substantial
+commercial, industrial or non-consumer uses, unless such uses represent
+the only significant mode of use of the product.
+
+ "Installation Information" for a User Product means any methods,
+procedures, authorization keys, or other information required to install
+and execute modified versions of a covered work in that User Product from
+a modified version of its Corresponding Source. The information must
+suffice to ensure that the continued functioning of the modified object
+code is in no case prevented or interfered with solely because
+modification has been made.
+
+ If you convey an object code work under this section in, or with, or
+specifically for use in, a User Product, and the conveying occurs as
+part of a transaction in which the right of possession and use of the
+User Product is transferred to the recipient in perpetuity or for a
+fixed term (regardless of how the transaction is characterized), the
+Corresponding Source conveyed under this section must be accompanied
+by the Installation Information. But this requirement does not apply
+if neither you nor any third party retains the ability to install
+modified object code on the User Product (for example, the work has
+been installed in ROM).
+
+ The requirement to provide Installation Information does not include a
+requirement to continue to provide support service, warranty, or updates
+for a work that has been modified or installed by the recipient, or for
+the User Product in which it has been modified or installed. Access to a
+network may be denied when the modification itself materially and
+adversely affects the operation of the network or violates the rules and
+protocols for communication across the network.
+
+ Corresponding Source conveyed, and Installation Information provided,
+in accord with this section must be in a format that is publicly
+documented (and with an implementation available to the public in
+source code form), and must require no special password or key for
+unpacking, reading or copying.
+
+ 7. Additional Terms.
+
+ "Additional permissions" are terms that supplement the terms of this
+License by making exceptions from one or more of its conditions.
+Additional permissions that are applicable to the entire Program shall
+be treated as though they were included in this License, to the extent
+that they are valid under applicable law. If additional permissions
+apply only to part of the Program, that part may be used separately
+under those permissions, but the entire Program remains governed by
+this License without regard to the additional permissions.
+
+ When you convey a copy of a covered work, you may at your option
+remove any additional permissions from that copy, or from any part of
+it. (Additional permissions may be written to require their own
+removal in certain cases when you modify the work.) You may place
+additional permissions on material, added by you to a covered work,
+for which you have or can give appropriate copyright permission.
+
+ Notwithstanding any other provision of this License, for material you
+add to a covered work, you may (if authorized by the copyright holders of
+that material) supplement the terms of this License with terms:
+
+ a) Disclaiming warranty or limiting liability differently from the
+ terms of sections 15 and 16 of this License; or
+
+ b) Requiring preservation of specified reasonable legal notices or
+ author attributions in that material or in the Appropriate Legal
+ Notices displayed by works containing it; or
+
+ c) Prohibiting misrepresentation of the origin of that material, or
+ requiring that modified versions of such material be marked in
+ reasonable ways as different from the original version; or
+
+ d) Limiting the use for publicity purposes of names of licensors or
+ authors of the material; or
+
+ e) Declining to grant rights under trademark law for use of some
+ trade names, trademarks, or service marks; or
+
+ f) Requiring indemnification of licensors and authors of that
+ material by anyone who conveys the material (or modified versions of
+ it) with contractual assumptions of liability to the recipient, for
+ any liability that these contractual assumptions directly impose on
+ those licensors and authors.
+
+ All other non-permissive additional terms are considered "further
+restrictions" within the meaning of section 10. If the Program as you
+received it, or any part of it, contains a notice stating that it is
+governed by this License along with a term that is a further
+restriction, you may remove that term. If a license document contains
+a further restriction but permits relicensing or conveying under this
+License, you may add to a covered work material governed by the terms
+of that license document, provided that the further restriction does
+not survive such relicensing or conveying.
+
+ If you add terms to a covered work in accord with this section, you
+must place, in the relevant source files, a statement of the
+additional terms that apply to those files, or a notice indicating
+where to find the applicable terms.
+
+ Additional terms, permissive or non-permissive, may be stated in the
+form of a separately written license, or stated as exceptions;
+the above requirements apply either way.
+
+ 8. Termination.
+
+ You may not propagate or modify a covered work except as expressly
+provided under this License. Any attempt otherwise to propagate or
+modify it is void, and will automatically terminate your rights under
+this License (including any patent licenses granted under the third
+paragraph of section 11).
+
+ However, if you cease all violation of this License, then your
+license from a particular copyright holder is reinstated (a)
+provisionally, unless and until the copyright holder explicitly and
+finally terminates your license, and (b) permanently, if the copyright
+holder fails to notify you of the violation by some reasonable means
+prior to 60 days after the cessation.
+
+ Moreover, your license from a particular copyright holder is
+reinstated permanently if the copyright holder notifies you of the
+violation by some reasonable means, this is the first time you have
+received notice of violation of this License (for any work) from that
+copyright holder, and you cure the violation prior to 30 days after
+your receipt of the notice.
+
+ Termination of your rights under this section does not terminate the
+licenses of parties who have received copies or rights from you under
+this License. If your rights have been terminated and not permanently
+reinstated, you do not qualify to receive new licenses for the same
+material under section 10.
+
+ 9. Acceptance Not Required for Having Copies.
+
+ You are not required to accept this License in order to receive or
+run a copy of the Program. Ancillary propagation of a covered work
+occurring solely as a consequence of using peer-to-peer transmission
+to receive a copy likewise does not require acceptance. However,
+nothing other than this License grants you permission to propagate or
+modify any covered work. These actions infringe copyright if you do
+not accept this License. Therefore, by modifying or propagating a
+covered work, you indicate your acceptance of this License to do so.
+
+ 10. Automatic Licensing of Downstream Recipients.
+
+ Each time you convey a covered work, the recipient automatically
+receives a license from the original licensors, to run, modify and
+propagate that work, subject to this License. You are not responsible
+for enforcing compliance by third parties with this License.
+
+ An "entity transaction" is a transaction transferring control of an
+organization, or substantially all assets of one, or subdividing an
+organization, or merging organizations. If propagation of a covered
+work results from an entity transaction, each party to that
+transaction who receives a copy of the work also receives whatever
+licenses to the work the party's predecessor in interest had or could
+give under the previous paragraph, plus a right to possession of the
+Corresponding Source of the work from the predecessor in interest, if
+the predecessor has it or can get it with reasonable efforts.
+
+ You may not impose any further restrictions on the exercise of the
+rights granted or affirmed under this License. For example, you may
+not impose a license fee, royalty, or other charge for exercise of
+rights granted under this License, and you may not initiate litigation
+(including a cross-claim or counterclaim in a lawsuit) alleging that
+any patent claim is infringed by making, using, selling, offering for
+sale, or importing the Program or any portion of it.
+
+ 11. Patents.
+
+ A "contributor" is a copyright holder who authorizes use under this
+License of the Program or a work on which the Program is based. The
+work thus licensed is called the contributor's "contributor version".
+
+ A contributor's "essential patent claims" are all patent claims
+owned or controlled by the contributor, whether already acquired or
+hereafter acquired, that would be infringed by some manner, permitted
+by this License, of making, using, or selling its contributor version,
+but do not include claims that would be infringed only as a
+consequence of further modification of the contributor version. For
+purposes of this definition, "control" includes the right to grant
+patent sublicenses in a manner consistent with the requirements of
+this License.
+
+ Each contributor grants you a non-exclusive, worldwide, royalty-free
+patent license under the contributor's essential patent claims, to
+make, use, sell, offer for sale, import and otherwise run, modify and
+propagate the contents of its contributor version.
+
+ In the following three paragraphs, a "patent license" is any express
+agreement or commitment, however denominated, not to enforce a patent
+(such as an express permission to practice a patent or covenant not to
+sue for patent infringement). To "grant" such a patent license to a
+party means to make such an agreement or commitment not to enforce a
+patent against the party.
+
+ If you convey a covered work, knowingly relying on a patent license,
+and the Corresponding Source of the work is not available for anyone
+to copy, free of charge and under the terms of this License, through a
+publicly available network server or other readily accessible means,
+then you must either (1) cause the Corresponding Source to be so
+available, or (2) arrange to deprive yourself of the benefit of the
+patent license for this particular work, or (3) arrange, in a manner
+consistent with the requirements of this License, to extend the patent
+license to downstream recipients. "Knowingly relying" means you have
+actual knowledge that, but for the patent license, your conveying the
+covered work in a country, or your recipient's use of the covered work
+in a country, would infringe one or more identifiable patents in that
+country that you have reason to believe are valid.
+
+ If, pursuant to or in connection with a single transaction or
+arrangement, you convey, or propagate by procuring conveyance of, a
+covered work, and grant a patent license to some of the parties
+receiving the covered work authorizing them to use, propagate, modify
+or convey a specific copy of the covered work, then the patent license
+you grant is automatically extended to all recipients of the covered
+work and works based on it.
+
+ A patent license is "discriminatory" if it does not include within
+the scope of its coverage, prohibits the exercise of, or is
+conditioned on the non-exercise of one or more of the rights that are
+specifically granted under this License. You may not convey a covered
+work if you are a party to an arrangement with a third party that is
+in the business of distributing software, under which you make payment
+to the third party based on the extent of your activity of conveying
+the work, and under which the third party grants, to any of the
+parties who would receive the covered work from you, a discriminatory
+patent license (a) in connection with copies of the covered work
+conveyed by you (or copies made from those copies), or (b) primarily
+for and in connection with specific products or compilations that
+contain the covered work, unless you entered into that arrangement,
+or that patent license was granted, prior to 28 March 2007.
+
+ Nothing in this License shall be construed as excluding or limiting
+any implied license or other defenses to infringement that may
+otherwise be available to you under applicable patent law.
+
+ 12. No Surrender of Others' Freedom.
+
+ If conditions are imposed on you (whether by court order, agreement or
+otherwise) that contradict the conditions of this License, they do not
+excuse you from the conditions of this License. If you cannot convey a
+covered work so as to satisfy simultaneously your obligations under this
+License and any other pertinent obligations, then as a consequence you may
+not convey it at all. For example, if you agree to terms that obligate you
+to collect a royalty for further conveying from those to whom you convey
+the Program, the only way you could satisfy both those terms and this
+License would be to refrain entirely from conveying the Program.
+
+ 13. Use with the GNU Affero General Public License.
+
+ Notwithstanding any other provision of this License, you have
+permission to link or combine any covered work with a work licensed
+under version 3 of the GNU Affero General Public License into a single
+combined work, and to convey the resulting work. The terms of this
+License will continue to apply to the part which is the covered work,
+but the special requirements of the GNU Affero General Public License,
+section 13, concerning interaction through a network will apply to the
+combination as such.
+
+ 14. Revised Versions of this License.
+
+ The Free Software Foundation may publish revised and/or new versions of
+the GNU General Public License from time to time. Such new versions will
+be similar in spirit to the present version, but may differ in detail to
+address new problems or concerns.
+
+ Each version is given a distinguishing version number. If the
+Program specifies that a certain numbered version of the GNU General
+Public License "or any later version" applies to it, you have the
+option of following the terms and conditions either of that numbered
+version or of any later version published by the Free Software
+Foundation. If the Program does not specify a version number of the
+GNU General Public License, you may choose any version ever published
+by the Free Software Foundation.
+
+ If the Program specifies that a proxy can decide which future
+versions of the GNU General Public License can be used, that proxy's
+public statement of acceptance of a version permanently authorizes you
+to choose that version for the Program.
+
+ Later license versions may give you additional or different
+permissions. However, no additional obligations are imposed on any
+author or copyright holder as a result of your choosing to follow a
+later version.
+
+ 15. Disclaimer of Warranty.
+
+ THERE IS NO WARRANTY FOR THE PROGRAM, TO THE EXTENT PERMITTED BY
+APPLICABLE LAW. EXCEPT WHEN OTHERWISE STATED IN WRITING THE COPYRIGHT
+HOLDERS AND/OR OTHER PARTIES PROVIDE THE PROGRAM "AS IS" WITHOUT WARRANTY
+OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, BUT NOT LIMITED TO,
+THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
+PURPOSE. THE ENTIRE RISK AS TO THE QUALITY AND PERFORMANCE OF THE PROGRAM
+IS WITH YOU. SHOULD THE PROGRAM PROVE DEFECTIVE, YOU ASSUME THE COST OF
+ALL NECESSARY SERVICING, REPAIR OR CORRECTION.
+
+ 16. Limitation of Liability.
+
+ IN NO EVENT UNLESS REQUIRED BY APPLICABLE LAW OR AGREED TO IN WRITING
+WILL ANY COPYRIGHT HOLDER, OR ANY OTHER PARTY WHO MODIFIES AND/OR CONVEYS
+THE PROGRAM AS PERMITTED ABOVE, BE LIABLE TO YOU FOR DAMAGES, INCLUDING ANY
+GENERAL, SPECIAL, INCIDENTAL OR CONSEQUENTIAL DAMAGES ARISING OUT OF THE
+USE OR INABILITY TO USE THE PROGRAM (INCLUDING BUT NOT LIMITED TO LOSS OF
+DATA OR DATA BEING RENDERED INACCURATE OR LOSSES SUSTAINED BY YOU OR THIRD
+PARTIES OR A FAILURE OF THE PROGRAM TO OPERATE WITH ANY OTHER PROGRAMS),
+EVEN IF SUCH HOLDER OR OTHER PARTY HAS BEEN ADVISED OF THE POSSIBILITY OF
+SUCH DAMAGES.
+
+ 17. Interpretation of Sections 15 and 16.
+
+ If the disclaimer of warranty and limitation of liability provided
+above cannot be given local legal effect according to their terms,
+reviewing courts shall apply local law that most closely approximates
+an absolute waiver of all civil liability in connection with the
+Program, unless a warranty or assumption of liability accompanies a
+copy of the Program in return for a fee.
+
+ END OF TERMS AND CONDITIONS
+
+ How to Apply These Terms to Your New Programs
+
+ If you develop a new program, and you want it to be of the greatest
+possible use to the public, the best way to achieve this is to make it
+free software which everyone can redistribute and change under these terms.
+
+ To do so, attach the following notices to the program. It is safest
+to attach them to the start of each source file to most effectively
+state the exclusion of warranty; and each file should have at least
+the "copyright" line and a pointer to where the full notice is found.
+
+
+ Copyright (C)
+
+ This program is free software: you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published by
+ the Free Software Foundation, either version 3 of the License, or
+ (at your option) any later version.
+
+ This program is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ GNU General Public License for more details.
+
+ You should have received a copy of the GNU General Public License
+ along with this program. If not, see .
+
+Also add information on how to contact you by electronic and paper mail.
+
+ If the program does terminal interaction, make it output a short
+notice like this when it starts in an interactive mode:
+
+ Copyright (C)
+ This program comes with ABSOLUTELY NO WARRANTY; for details type `show w'.
+ This is free software, and you are welcome to redistribute it
+ under certain conditions; type `show c' for details.
+
+The hypothetical commands `show w' and `show c' should show the appropriate
+parts of the General Public License. Of course, your program's commands
+might be different; for a GUI interface, you would use an "about box".
+
+ You should also get your employer (if you work as a programmer) or school,
+if any, to sign a "copyright disclaimer" for the program, if necessary.
+For more information on this, and how to apply and follow the GNU GPL, see
+.
+
+ The GNU General Public License does not permit incorporating your program
+into proprietary programs. If your program is a subroutine library, you
+may consider it more useful to permit linking proprietary applications with
+the library. If this is what you want to do, use the GNU Lesser General
+Public License instead of this License. But first, please read
+.
diff --git a/LICENSE-YEHOWSHUA b/LICENSE-YEHOWSHUA
new file mode 100644
index 0000000..180914d
--- /dev/null
+++ b/LICENSE-YEHOWSHUA
@@ -0,0 +1,2 @@
+This codebase is also licensed to Yehowshua Immanuel to use
+in any manner Yehowshua Immanuel sees fit.
\ No newline at end of file
diff --git a/README.md b/README.md
index 8235c1f..7890a1e 100644
--- a/README.md
+++ b/README.md
@@ -1,43 +1,131 @@
-# The Beginnings of a high-performance, low memory footprint VCD Viewer in Rust for massive multi-GB waveforms
+Copyright(2023) - Yehowshua Immanuel
-## Features
- - very fast
- - loads 200MB of VCD waveform per second on an 8 core 2017 desktop CPU with NVMe storage
- - consumes roughly between 10 - 50MB of memory per GB of waveform
- - elegant/pretty UI
- - can be easily ported to work in browser via webassembly
- - allows high-performance custom Rust plugins to manipulate and
- generate new waveforms live
+# Vision
+Imagine being able to visualize a CPU pipeline diagram by merely loading a simulation waveform dump, sprinkling in a bit of code, and dragging and dropping some diagram blocks into the visualizer. This project aims to offer such an experience.
-## Running
+Since this project is written in Rust, it should also be able to run in the browser via web-assembly.
-Make sure you have a test vcd file to get you started. You can grab
-a large VCD file from
+# Status
+As of January 2024, work on the Fastwave Backend is stalled. It has been a fun journey watching Fastwave enable the first iterations of the [surfer waveform viewer](https://surfer-project.org). Now surfer uses an even better backend called [Wellen](https://github.com/ekiwi/wellen?tab=readme-ov-file). Go check it out! I hear it's really good. Perhaps I will soon archive the Fastwave Backend.
+
+Browser demo: https://app.surfer-project.org/
+
+Screenshot of surfer frontend below:
+
+
+# A High performance, VCD Parser written in Rust
+
+I hope for a GUI that eventually looks like the following...
+
+
+
+# Current Features
+
+ - Robust Error Handling
+
+ FastWave currently offers highly robust error handling(at least on the sample
+ VCD files in this repository) which GTKWave doesn't have. For
+ example, selecting the ``UTILIZATON_ENABLED`` signal after opening
+ [test2x2_regex22_string1.vcd](./test-vcd-files/xilinx_isim/test2x2_regex22_string1.vcd)
+ (one of the sample xilinx vcd test files) in GtkWave, will crash GtkWave since
+ this signal is malformed. FastWave on the otherhand simply notes that the
+ signal is malformed.
+
+# Performance
+
+## Methods
+I have been testing performance on a 3.04GB VCD file that can be found
[here](https://drive.google.com/file/d/1pfm2qo2l8fGTHHJ8TLrg1vSGaV_TUbp2/view?usp=sharing).
+For getting the GtkWave results, I fired up GtkWave, clicked on
+``File``->``Open New Window``, and selected the VCD file linked to above.
+I started my stopwatch as soon as I pressed enter to beging loading the VCD
+file, and stopped my stopwatch once the GtkWave titlebar reached 100%.
+
+To get the memory consumption, I opened Activity Monitor on Mac, and recorded
+the GtkWave memory usage before and after loading the large VCD file, and
+took the difference.
+
+I noticed that when running FastWave in the VsCode terminal as opposed
+to the MacOS system terminal or the Lapce terminal, FastWave is notably
+slower.
+
+## Results
+
+LZ4 should really improve memory usage once I add it. Note that GTKWave uses LZ4 on the fly.
+
+| Software | Time(s) | Memory(MB) |
+|----------|---------|------------|
+| FastWave | ~27.30 | 1100+ |
+| GtkWave | ~30 | 89.8 |
+
+
+# Current Limitations
+Unable to handle VCD files that have signals with more than
+2^32 - 1 = 4,294,967,295 deltas/changes.
+
+# Running
+
+This repository comes with several smaller VCD files emitted from
+various EDA tools. If you want a larger VCD file, grab one from
+[here](https://drive.google.com/file/d/1pfm2qo2l8fGTHHJ8TLrg1vSGaV_TUbp2/view?usp=sharing).
+
+Here are some examples you can run:
The first build of the program may take some time.
-``cargo run --release -- path/to/vcd/file``
+1. ``cargo run --release --example parse_vcd tests/vcd-files/aldec/SPI_Write.vcd``
+2. ``cargo run --release --example vcd``
-## TODO
- - [x] Test positions with seeking
- - [x] vcd should be argument
- - [x] structure to store stream position against timestamp as string
- - [x] structure to store stream position against timestamp as BigInt
+You can run all the tests with ``cargo test``
-### April 14
- - [ ] store timestamps to struct
- - [ ] Get file loading status
- - [ ] Get all signal scopes
+# Testing on Bad Files
+You may wish to test the parser on a malformed VCD just to make
+sure that the parser gives useful/sane errors.
-### April 15
- - [ ] Re-factor to support hooks in the initial file ingest
- - [ ] Modularize
+Here's a command to test on a malformed VCD:
+``cargo run --release --example parse_vcd tests/vcd-files/VCD_file_with_errors.vcd``
-### April 15
- - [ ] Build tree per signal.
- - [ ] Each signal also comes with a value change buffer to
- avoid frequent disk readouts.
-# VCD Spec Questions
-- [ ] I'm pretty sure that only one statement per line is allowed.
\ No newline at end of file
+# TODO
+
+## Features and Other
+ - [ ] add documenting comments
+ - [ ] make signal query private until later?
+ - [ ] add signal query code to example once interface is finalized
+ - [ ] change crate name to vcd_fast_parse
+ - [ ] perhaps we should be looking up signal values on the VCD class
+ - [ ] perhaps we should be returning signal trees from the VCD class
+ - [ ] add lz4 compression support and compare memory perf before and after
+ - [ ] may need to refactor with allow for get_mut for dynamic
+ compression-decompression for multiple signal structs
+ at once to allow for multi-threading
+ - [ ] test against large waveforms from the
+ [verilog-vcd-parser](https://github.com/ben-marshall/verilog-vcd-parser)
+ tool
+ - [ ] (a bit of work) consolidate error messages in validation phase
+ - [ ] once the access patterns of the GUI frontend are well understood,
+ create specific functions and restrict as many types to private
+ as possible
+ - [ ] Print out git commit or release number.
+ - [ ] do a read through all the code - look for uneeded code
+ - [ ] Move part of the performance section to another markdown file.
+
+## Repairs
+ - [ ] replace str bracket indices with get(slice)
+ - [ ] make a custom date parser for possibly up to 18 different versions(that is, for each possible tool).
+ - [ ] Consolidate error messages and add cursors throughout.
+ - [ ] Add file and line to the enum errors.
+ - [ ] Fix warnings especially usage and restriction warnings once I'm
+ able to successfully parse all sample VCDs.
+
+## Code Consistency
+ - [ ] Change error messages to line and filenames. Go through all calls to unwrap.
+ - [ ] search for any unwraps or any direct vectors indexing
+ - [ ] Handle TODOs
+ - [ ] Remove debug code/comments.
+
+## Documentation
+ - [ ] Document indexing structure with diagram and possibly include the rational
+
+## Marketing
+ - [ ] Send survey to community
diff --git a/assets/FastWaveMockup.png b/assets/FastWaveMockup.png
new file mode 100644
index 0000000..fbf030b
Binary files /dev/null and b/assets/FastWaveMockup.png differ
diff --git a/examples/parse_vcd.rs b/examples/parse_vcd.rs
new file mode 100644
index 0000000..b1478c3
--- /dev/null
+++ b/examples/parse_vcd.rs
@@ -0,0 +1,33 @@
+// Copyright (C) 2022 Yehowshua Immanuel
+// This program is distributed under both the GPLV3 license
+// and the YEHOWSHUA license, both of which can be found at
+// the root of the folder containing the sources for this program.
+use clap::Parser;
+use std::fs::File;
+
+use fastwave_backend::parse_vcd;
+
+#[derive(Parser)]
+struct Cli {
+ /// The path to the file to read
+ path: std::path::PathBuf,
+}
+
+fn main() -> std::io::Result<()> {
+ let args = Cli::parse();
+
+ use std::time::Instant;
+
+ let now = Instant::now();
+ let file = File::open(&args.path)?;
+ parse_vcd(file).unwrap();
+ let elapsed = now.elapsed();
+
+ println!(
+ "Parsed VCD file {} : {:.2?}",
+ &args.path.as_os_str().to_str().unwrap(),
+ elapsed
+ );
+
+ Ok(())
+}
diff --git a/examples/vcd.rs b/examples/vcd.rs
new file mode 100644
index 0000000..eb6b660
--- /dev/null
+++ b/examples/vcd.rs
@@ -0,0 +1,81 @@
+// Copyright (C) 2022 Yehowshua Immanuel
+// This program is distributed under both the GPLV3 license
+// and the YEHOWSHUA license, both of which can be found at
+// the root of the folder containing the sources for this program.
+use std::fs::File;
+
+use fastwave_backend::{parse_vcd, ScopeIdx, SignalIdx, VCD};
+
+fn indented_print(indent: u8, name: &String) {
+ for _ in 0..indent {
+ print!(" |");
+ }
+ print!("---");
+ println!("{name}");
+}
+
+// TODO: refactor into more general visitor pattern that takes a
+// function as an argument.
+fn visit_all_scopes(vcd: &VCD) {
+ fn visit_all_scope_children(root_idx: ScopeIdx, vcd: &VCD, indent: u8) {
+ if vcd.child_scopes_by_idx(root_idx).is_empty() {
+ } else {
+ for child_scope_idx in vcd.child_scopes_by_idx(root_idx) {
+ indented_print(indent, vcd.scope_name_by_idx(child_scope_idx));
+ for signal_idx in vcd.get_children_signal_idxs(child_scope_idx) {
+ let signal = vcd.signal_from_signal_idx(signal_idx);
+ let SignalIdx(idx) = signal_idx;
+ indented_print(indent + 1, &format!("{},{}", signal.name(), idx));
+ }
+ visit_all_scope_children(child_scope_idx, vcd, indent + 1);
+ }
+ }
+ }
+ for root_scope_idx in vcd.root_scopes_by_idx() {
+ indented_print(0, vcd.scope_name_by_idx(root_scope_idx));
+ visit_all_scope_children(root_scope_idx, vcd, 1u8);
+ }
+}
+
+fn main() -> std::io::Result<()> {
+ use std::time::Instant;
+
+ // we start by printing out the entire signal tree of
+ // a parsed VCD
+ let now = Instant::now();
+ let file_path = "tests/vcd-files/icarus/CPU.vcd";
+ let file = File::open(file_path)?;
+ let vcd = parse_vcd(file).unwrap();
+ let elapsed = now.elapsed();
+ println!("Parsed VCD file {} : {:.2?}", file_path, elapsed);
+
+ println!("Printing Scopes");
+ visit_all_scopes(&vcd);
+ println!("Done Printing Scopes");
+ println!();
+
+ // we then parse another VCD, print its signal tree and
+ // query some values on its timeline
+ let now = Instant::now();
+ let file_path = "tests/vcd-files/amaranth/up_counter.vcd";
+ let file = File::open(file_path)?;
+ let vcd = parse_vcd(file).unwrap();
+ let elapsed = now.elapsed();
+ println!("Parsed VCD file {} : {:.2?}", file_path, elapsed);
+
+ println!("Printing Scopes");
+ visit_all_scopes(&vcd);
+ println!("Done Printing Scopes");
+
+ let state_signal = vcd.signal_from_signal_idx(SignalIdx(4));
+ let name = state_signal.name();
+
+ let timestamps = vec![31499_000u32, 31500_000u32, 57760_000u32];
+ for timestamp in timestamps {
+ let time = num::BigUint::from(timestamp);
+ let val = state_signal.query_string_val_on_tmln(&time, &vcd).unwrap();
+ println!("Signal `{name}` has value `{val}` at time `{time}`");
+ }
+
+ Ok(())
+}
diff --git a/src/lib.rs b/src/lib.rs
new file mode 100644
index 0000000..6bdb055
--- /dev/null
+++ b/src/lib.rs
@@ -0,0 +1,12 @@
+// Copyright (C) 2022 Yehowshua Immanuel
+// This program is distributed under both the GPLV3 license
+// and the YEHOWSHUA license, both of which can be found at
+// the root of the folder containing the sources for this program.
+
+mod vcd;
+pub use vcd::parse::parse_vcd;
+pub use vcd::signal::{Signal, SignalType, SignalValue, SignalErrors};
+pub use vcd::types::{Metadata, Timescale, Version};
+pub use vcd::types::{ScopeIdx, SignalIdx, VCD};
+
+pub use num::BigUint;
diff --git a/src/main.rs b/src/main.rs
deleted file mode 100644
index 5423c94..0000000
--- a/src/main.rs
+++ /dev/null
@@ -1,60 +0,0 @@
-use std::io::prelude::*;
-use std::io;
-use std::fs::File;
-
-use num::*;
-use clap::Parser;
-
-#[derive(Parser)]
-struct Cli {
- /// The path to the file to read
- #[clap(parse(from_os_str))]
- path: std::path::PathBuf,
-}
-
-struct Timestamp{
- file_offset: u64,
- timestamp: BigInt
-}
-
-fn main() -> std::io::Result<()> {
- let args = Cli::parse();
-
- let file = File::open(&args.path)?;
- let mut reader = io::BufReader::new(file);
-
- let mut buffer = String::new();
- let mut timestamp_offsets = Vec::new();
- let mut timestamps = Vec::new();
-
- while {
- let bytes_read = reader.read_line(&mut buffer).unwrap();
- bytes_read > 0
- } {
- if &buffer[0..1] == "#" {
- let pos = reader.stream_position().unwrap();
- timestamp_offsets.push(pos);
-
- let timestamp = {
- let len = buffer.len();
- let str_val = &buffer[1..(len - 1)].as_bytes();
- BigInt::parse_bytes(str_val, 10).unwrap()
- };
- timestamps.push(timestamp);
- }
- buffer.clear()
- }
-
- let index = 4;
- let timestamp_offset = timestamp_offsets.get(index).unwrap();
- let timestamp = timestamps.get(index).unwrap();
- dbg!((timestamp_offset, timestamp));
-
- // seek to where we found the first timestamp and read
- // out the next line
- reader.seek(io::SeekFrom::Start(*timestamp_offset));
- reader.read_line(&mut buffer);
- dbg!(buffer);
-
- Ok(())
-}
diff --git a/src/vcd.rs b/src/vcd.rs
new file mode 100644
index 0000000..53641e1
--- /dev/null
+++ b/src/vcd.rs
@@ -0,0 +1,10 @@
+// Copyright (C) 2022 Yehowshua Immanuel
+// This program is distributed under both the GPLV3 license
+// and the YEHOWSHUA license, both of which can be found at
+// the root of the folder containing the sources for this program.
+
+pub(crate) mod parse;
+mod reader;
+pub(crate) mod signal;
+pub(crate) mod types;
+mod utilities;
diff --git a/src/vcd/parse.rs b/src/vcd/parse.rs
new file mode 100644
index 0000000..7ff2f89
--- /dev/null
+++ b/src/vcd/parse.rs
@@ -0,0 +1,35 @@
+// Copyright (C) 2022 Yehowshua Immanuel
+// This program is distributed under both the GPLV3 license
+// and the YEHOWSHUA license, both of which can be found at
+// the root of the folder containing the sources for this program.
+
+mod combinator_atoms;
+mod events;
+mod metadata;
+mod scopes;
+mod types;
+
+pub fn parse_vcd(file: impl std::io::Read) -> Result {
+ let mut word_gen = super::reader::WordReader::new(file);
+
+ let header = metadata::parse_metadata(&mut word_gen)?;
+
+ // later, we'll need to map parsed ascii symbols to their
+ // respective signal indexes
+ let mut signal_map = std::collections::HashMap::new();
+
+ // after we parse metadata, we form the VCD object
+ let mut vcd = super::types::VCD {
+ metadata: header,
+ tmstmps_encoded_as_u8s: vec![],
+ all_signals: vec![],
+ all_scopes: vec![],
+ root_scopes: vec![],
+ largest_timestamp: None,
+ };
+
+ scopes::parse_scopes(&mut word_gen, &mut vcd, &mut signal_map)?;
+ events::parse_events(&mut word_gen, &mut vcd, &mut signal_map)?;
+
+ Ok(vcd)
+}
diff --git a/src/vcd/parse/combinator_atoms.rs b/src/vcd/parse/combinator_atoms.rs
new file mode 100644
index 0000000..d2f9bf9
--- /dev/null
+++ b/src/vcd/parse/combinator_atoms.rs
@@ -0,0 +1,83 @@
+// Copyright (C) 2022 Yehowshua Immanuel
+// This program is distributed under both the GPLV3 license
+// and the YEHOWSHUA license, both of which can be found at
+// the root of the folder containing the sources for this program.
+use super::super::reader::{next_word, WordReader};
+use super::types::ParseResult;
+
+pub(super) fn digit(chr: u8) -> bool {
+ let zero = b'0';
+ let nine = b'9';
+
+ (chr >= zero) && (nine >= chr)
+}
+
+pub(super) fn take_until(word: &str, pattern: u8) -> ParseResult<'_> {
+ let mut new_start = 0;
+
+ for chr in word.as_bytes() {
+ if *chr == pattern {
+ break;
+ } else {
+ new_start += 1;
+ }
+ }
+
+ ParseResult {
+ matched: &word[0..new_start],
+ residual: &word[new_start..],
+ }
+}
+
+pub(super) fn take_while(word: &str, cond: fn(u8) -> bool) -> ParseResult<'_> {
+ let mut new_start = 0;
+
+ for chr in word.as_bytes() {
+ if cond(*chr) {
+ new_start += 1;
+ } else {
+ break;
+ }
+ }
+
+ ParseResult {
+ matched: &word[0..new_start],
+ residual: &word[new_start..],
+ }
+}
+
+pub(super) fn tag<'a>(word: &'a str, pattern: &'a str) -> ParseResult<'a> {
+ let lhs = word.as_bytes().iter();
+ let rhs = pattern.as_bytes();
+ let iter = lhs.zip(rhs);
+ let mut new_start = 0;
+
+ let mut res = true;
+ for (c_lhs, c_rhs) in iter {
+ res = res && (c_lhs == c_rhs);
+ if !res {
+ break;
+ }
+ new_start += 1;
+ }
+
+ ParseResult {
+ matched: &word[0..new_start],
+ residual: &word[new_start..],
+ }
+}
+
+pub(super) fn ident(
+ word_reader: &mut WordReader,
+ keyword: &str,
+) -> Result<(), String> {
+ // let keyword = "module";
+ let (word, cursor) = next_word!(word_reader)?;
+
+ if word == keyword {
+ Ok(())
+ } else {
+ let err = format!("found keyword `{word}` but expected `{keyword}` on {cursor:?}");
+ Err(err)
+ }
+}
diff --git a/src/vcd/parse/events.rs b/src/vcd/parse/events.rs
new file mode 100644
index 0000000..3f42048
--- /dev/null
+++ b/src/vcd/parse/events.rs
@@ -0,0 +1,546 @@
+// Copyright (C) 2022 Yehowshua Immanuel
+// This program is distributed under both the GPLV3 license
+// and the YEHOWSHUA license, both of which can be found at
+// the root of the folder containing the sources for this program.
+
+use num::BigUint;
+use std::collections::HashMap;
+
+use super::super::reader::{next_word, Cursor, Line, Word, WordReader};
+use super::super::signal::{LsbIdxOfTmstmpValOnTmln, SignalEnum};
+use super::super::types::{SignalIdx, VCD};
+use super::super::utilities::{binary_str_to_vec_u8, BinaryParserErrTypes};
+
+pub(super) fn parse_events(
+ word_reader: &mut WordReader,
+ vcd: &mut VCD,
+ signal_map: &mut HashMap,
+) -> Result<(), String> {
+ let mut curr_tmstmp_lsb_idx = 0u32;
+ let mut curr_tmstmp_len_u8 = 0u8;
+ loop {
+ let next_word = word_reader.next_word();
+
+ // The following is the only case where eof is not an error.
+ // If we've reached the end of the file, then there is obviously
+ // nothing left to do...
+ if next_word.is_none() {
+ break;
+ };
+
+ let (word, cursor) = next_word.unwrap();
+ let Cursor(Line(_), Word(word_in_line_idx)) = cursor;
+ // we only want to match on the first word in a line
+ if word_in_line_idx != 1 {
+ continue;
+ }
+ match &word[0..1] {
+ "$" => {}
+ "#" => {
+ let value = &word[1..];
+ let (f, l) = (file!(), line!());
+ let value_biguint = BigUint::parse_bytes(value.as_bytes(), 10)
+ .ok_or(())
+ .map_err(|_| {
+ format!(
+ "Error near {f}:{l}. Failed to parse {value} as BigInt at {cursor:?}"
+ )
+ })?;
+ let mut value = value_biguint.to_bytes_le();
+ // TODO : u32 helps with less memory, but should ideally likely be
+ // configurable.
+ curr_tmstmp_len_u8 = u8::try_from(value.len()).map_err(|_| {
+ format!(
+ "Error near {}:{}. Failed to convert from usize to u8.",
+ file!(),
+ line!()
+ )
+ })?;
+ curr_tmstmp_lsb_idx =
+ u32::try_from(vcd.tmstmps_encoded_as_u8s.len()).map_err(|_| {
+ format!(
+ "Error near {}:{}. Failed to convert from usize to u32.",
+ file!(),
+ line!()
+ )
+ })?;
+ vcd.tmstmps_encoded_as_u8s.append(&mut value);
+ vcd.largest_timestamp = Some(value_biguint);
+ }
+
+ // handle the case of an n bit signal whose value must be parsed
+ "b" => {
+ let binary_value = &word[1..];
+ let observed_num_bits = u32::try_from(binary_value.len()).map_err(|_| {
+ format!(
+ "Error near {}:{}, {cursor:?}. \
+ Found signal with more than 2^32 - 1 bits.",
+ file!(),
+ line!()
+ )
+ })?;
+
+ let mut value_u8: Vec = Vec::new();
+ let mut value_string = String::new();
+
+ let mut store_as_string = false;
+
+ // If we encounter other values than 0 or 1, we can recover from
+ // the error and store the value as a string.
+ // Or else, we propagate up other errors.
+ match binary_str_to_vec_u8(binary_value) {
+ Ok(result) => {
+ value_u8 = result;
+ }
+ Err(
+ BinaryParserErrTypes::XValue
+ | BinaryParserErrTypes::ZValue
+ | BinaryParserErrTypes::UValue
+ | BinaryParserErrTypes::WValue
+ | BinaryParserErrTypes::HValue
+ | BinaryParserErrTypes::DashValue
+ | BinaryParserErrTypes::LValue,
+ ) => {
+ store_as_string = true;
+ // Turn to lower case for consistency
+ value_string = binary_value.to_ascii_lowercase();
+ }
+ Err(e) => {
+ let (f, l) = (file!(), line!());
+ Err(e).map_err(|e| {
+ format!("Error near {f}:{l}. Error {e:?} at {cursor:?}.")
+ })?;
+ }
+ }
+
+ // this word should be the signal alias
+ let (word, cursor) = next_word!(word_reader)?;
+
+ // lookup signal idx
+ let signal_idx = signal_map.get(word).ok_or(()).map_err(|_| {
+ format!(
+ "Error near {}:{}. Failed to lookup signal {word} at {cursor:?}",
+ file!(),
+ line!()
+ )
+ })?;
+
+ let signal = vcd.dealiasing_signal_idx_to_signal_lookup_mut(signal_idx)?;
+
+ match signal {
+ SignalEnum::Data {
+ name,
+ signal_type,
+ ref mut signal_error,
+ num_bits,
+ num_bytes,
+ nums_encoded_as_fixed_width_le_u8,
+ string_vals,
+ lsb_indxs_of_num_tmstmp_vals_on_tmln,
+ byte_len_of_num_tmstmp_vals_on_tmln,
+ lsb_indxs_of_string_tmstmp_vals_on_tmln,
+ byte_len_of_string_tmstmp_vals_on_tmln,
+ ..
+ } => {
+ // we've already identified in a prior loop iteration that the signal has
+ // an error
+ if signal_error.is_some() {
+ continue;
+ }
+
+ // Get the observed number of bits for the value parsed earlier
+ // and verify that it is not greater than the numbits declared
+ // when the signal was declared.
+ // Also account for the error case of a bitwidth of `None`
+ match num_bits {
+ Some(ref num_bits) => {
+ if observed_num_bits > *num_bits {
+ let (f, l) = (file!(), line!());
+ let msg = format!("\
+ Error near {f}:{l}. The bitwidth for signal {name} \
+ of signal_type {signal_type:?} is expected to be `{num_bits}` not \
+ `{observed_num_bits}`. \
+ This error occurred while parsing the vcd file at \
+ {cursor:?}");
+ *signal_error = Some(msg);
+ continue;
+ }
+ }
+ None => {
+ let (f, l) = (file!(), line!());
+ let msg = format!(
+ "\
+ Error near {f}:{l}. The bitwidth for signal {name} \
+ must be specified for a signal of type {signal_type:?}. \
+ This error occurred while parsing the vcd file at \
+ {cursor:?}"
+ );
+ Err(msg)?;
+ }
+ };
+
+ if store_as_string {
+ lsb_indxs_of_string_tmstmp_vals_on_tmln
+ .push(LsbIdxOfTmstmpValOnTmln(curr_tmstmp_lsb_idx));
+ byte_len_of_string_tmstmp_vals_on_tmln.push(curr_tmstmp_len_u8);
+ string_vals.push(value_string);
+ Ok(())
+ } else {
+ // timestamp stuff
+ lsb_indxs_of_num_tmstmp_vals_on_tmln
+ .push(LsbIdxOfTmstmpValOnTmln(curr_tmstmp_lsb_idx));
+ byte_len_of_num_tmstmp_vals_on_tmln.push(curr_tmstmp_len_u8);
+
+ // value stuff
+ // we may need to zero extend values
+ // so that we end up storing all values
+ // of a particular signal in a consistent
+ // amount of bytes
+ let bytes_required = num_bytes.ok_or_else(|| {
+ format!("Error near {}:{}. num_bytes empty.", file!(), line!())
+ })?;
+ let mut curr_num_bytes =
+ u16::try_from(value_u8.len()).map_err(|_| {
+ format!(
+ "Error near {}:{}. \
+ Found signal {name} with with value change of greater \
+ than 2^32 - 1 bits on {cursor:?}.",
+ file!(),
+ line!()
+ )
+ })?;
+
+ nums_encoded_as_fixed_width_le_u8.append(&mut value_u8);
+ while curr_num_bytes < bytes_required {
+ nums_encoded_as_fixed_width_le_u8.push(0u8);
+ curr_num_bytes += 1;
+ }
+ Ok(())
+ }
+ }
+ SignalEnum::Alias { .. } => {
+ let (f, l) = (file!(), line!());
+ let msg = format!(
+ "Error near {f}:{l}, a signal alias should not point to a signal alias.\n\
+ This error occurred while parsing vcd file at {cursor:?}");
+ Err(msg)
+ }
+ }?;
+ }
+
+ // handle the case of a one bit signal whose value is set to `0`
+ "0" => {
+ // lookup signal idx
+ let hash = &word[1..];
+ let signal_idx = signal_map.get(hash).ok_or(()).map_err(|_| {
+ format!(
+ "Error near {}:{}. Failed to lookup signal {hash} at {cursor:?}",
+ file!(),
+ line!()
+ )
+ })?;
+
+ let signal = vcd.dealiasing_signal_idx_to_signal_lookup_mut(signal_idx)?;
+
+ match signal {
+ SignalEnum::Data {
+ name,
+ signal_type,
+ ref mut signal_error,
+ num_bits,
+ num_bytes,
+ nums_encoded_as_fixed_width_le_u8,
+ lsb_indxs_of_num_tmstmp_vals_on_tmln,
+ byte_len_of_num_tmstmp_vals_on_tmln,
+ ..
+ } => {
+ // if this is a bad signal, go ahead and skip it
+ if signal_error.is_some() {
+ continue;
+ }
+
+ // Get bitwidth and verify that it is 1.
+ // Also account for the error case of a bitwidth of `None`
+ match num_bits {
+ Some(ref num_bits) => {
+ if *num_bits != 1 {
+ let (f, l) = (file!(), line!());
+ let msg = format!(
+ "\
+ Error near {f}:{l}. The bitwidth for signal {name} \
+ of signal_type {signal_type:?} is expected to be `1` not \
+ `{num_bits}`. \
+ This error occurred while parsing the vcd file at \
+ {cursor:?}"
+ );
+ *signal_error = Some(msg);
+ continue;
+ }
+ }
+ None => {
+ let (f, l) = (file!(), line!());
+ let msg = format!(
+ "\
+ Error near {f}:{l}. The bitwidth for signal {name} \
+ must be specified for a signal of type {signal_type:?}. \
+ This error occurred while parsing the vcd file at \
+ {cursor:?}"
+ );
+ Err(msg)?;
+ }
+ };
+ // timestamp stuff
+ lsb_indxs_of_num_tmstmp_vals_on_tmln
+ .push(LsbIdxOfTmstmpValOnTmln(curr_tmstmp_lsb_idx));
+ byte_len_of_num_tmstmp_vals_on_tmln.push(curr_tmstmp_len_u8);
+
+ // value stuff
+ // we may need to zero extend values
+ // so that we end up storing all values
+ // of a particular signal in a consistent
+ // amount of bytes
+ let bytes_required = num_bytes.ok_or_else(|| {
+ format!("Error near {}:{}. num_bytes empty.", file!(), line!())
+ })?;
+ nums_encoded_as_fixed_width_le_u8.push(0u8);
+ let mut curr_num_bytes = 1;
+ while curr_num_bytes < bytes_required {
+ nums_encoded_as_fixed_width_le_u8.push(0u8);
+ curr_num_bytes += 1;
+ }
+ Ok(())
+ }
+ SignalEnum::Alias { .. } => {
+ let (f, l) = (file!(), line!());
+ let msg = format!(
+ "Error near {f}:{l}, a signal alias should not point to a signal alias.\n\
+ This error occurred while parsing vcd file at {cursor:?}");
+ Err(msg)
+ }
+ }?;
+ }
+
+ "1" => {
+ // lokup signal idx
+ let hash = &word[1..];
+ let signal_idx = signal_map.get(hash).ok_or(()).map_err(|_| {
+ format!(
+ "Error near {}:{}. Failed to lookup signal {hash} at {cursor:?}",
+ file!(),
+ line!()
+ )
+ })?;
+
+ let signal = vcd.dealiasing_signal_idx_to_signal_lookup_mut(signal_idx)?;
+
+ match signal {
+ SignalEnum::Data {
+ name,
+ signal_type,
+ ref mut signal_error,
+ num_bits,
+ num_bytes,
+ nums_encoded_as_fixed_width_le_u8,
+ lsb_indxs_of_num_tmstmp_vals_on_tmln,
+ byte_len_of_num_tmstmp_vals_on_tmln,
+ ..
+ } => {
+ // if this is a bad signal, go ahead and skip it
+ if signal_error.is_some() {
+ continue;
+ }
+
+ // Get bitwidth and verify that it is 1.
+ // Also account for the error case of a bitwidth of `None`
+ match num_bits {
+ Some(ref num_bits) => {
+ if *num_bits != 1 {
+ let (f, l) = (file!(), line!());
+ let msg = format!(
+ "\
+ Error near {f}:{l}. The bitwidth for signal {name} \
+ of signal_type {signal_type:?} is expected to be `1` not \
+ `{num_bits}`. \
+ This error occurred while parsing the vcd file at \
+ {cursor:?}"
+ );
+ *signal_error = Some(msg);
+ continue;
+ }
+ }
+ None => {
+ let (f, l) = (file!(), line!());
+ let msg = format!(
+ "\
+ Error near {f}:{l}. The bitwidth for signal {name} \
+ must be specified for a signal of type {signal_type:?}. \
+ This error occurred while parsing the vcd file at \
+ {cursor:?}"
+ );
+ Err(msg)?;
+ }
+ };
+ // timestamp stuff
+ lsb_indxs_of_num_tmstmp_vals_on_tmln
+ .push(LsbIdxOfTmstmpValOnTmln(curr_tmstmp_lsb_idx));
+ byte_len_of_num_tmstmp_vals_on_tmln.push(curr_tmstmp_len_u8);
+
+ // value stuff
+ // we may need to zero extend values
+ // so that we end up storing all values
+ // of a particular signal in a consistent
+ // amount of bytes
+ let bytes_required = num_bytes.ok_or_else(|| {
+ format!("Error near {}:{}. num_bytes empty.", file!(), line!())
+ })?;
+ nums_encoded_as_fixed_width_le_u8.push(1u8);
+ let mut curr_num_bytes = 1;
+ while curr_num_bytes < bytes_required {
+ nums_encoded_as_fixed_width_le_u8.push(0u8);
+ curr_num_bytes += 1;
+ }
+ Ok(())
+ }
+ SignalEnum::Alias { .. } => {
+ let (f, l) = (file!(), line!());
+ let msg = format!(
+ "Error near {f}:{l}, a signal alias should not point to a signal alias.\n\
+ This error occurred while parsing vcd file at {cursor:?}");
+ Err(msg)
+ }
+ }?;
+ }
+
+ // other one bit cases
+ "x" | "X" | "z" | "Z" | "u" | "U" | "h" | "H" | "l" | "L" | "w" | "W" | "-" => {
+ // Select value and turn to lowercase for consistency
+ let val = word[0..1].to_ascii_lowercase();
+ // lokup signal idx
+ let hash = &word[1..];
+ let signal_idx = signal_map.get(hash).ok_or(()).map_err(|_| {
+ format!(
+ "Error near {}:{}. Failed to lookup signal {hash} at {cursor:?}",
+ file!(),
+ line!()
+ )
+ })?;
+
+ let signal = vcd.dealiasing_signal_idx_to_signal_lookup_mut(signal_idx)?;
+
+ match signal {
+ SignalEnum::Data {
+ name,
+ signal_type,
+ ref mut signal_error,
+ num_bits,
+ string_vals,
+ byte_len_of_string_tmstmp_vals_on_tmln,
+ lsb_indxs_of_string_tmstmp_vals_on_tmln,
+ ..
+ } => {
+ // if this is a bad signal, go ahead and skip it
+ if signal_error.is_some() {
+ continue;
+ }
+
+ // Get bitwidth and verify that it is 1.
+ // Also account for the error case of a bitwidth of `None`
+ match num_bits {
+ Some(ref num_bits) => {
+ if *num_bits != 1 {
+ let (f, l) = (file!(), line!());
+ let msg = format!(
+ "\
+ Error near {f}:{l}. The bitwidth for signal {name} \
+ of signal_type {signal_type:?} is expected to be `1` not \
+ `{num_bits}`. \
+ This error occurred while parsing the vcd file at \
+ {cursor:?}"
+ );
+ *signal_error = Some(msg);
+ continue;
+ }
+ }
+ None => {
+ let (f, l) = (file!(), line!());
+ let msg = format!(
+ "\
+ Error near {f}:{l}. The bitwidth for signal {name} \
+ must be specified for a signal of type {signal_type:?}. \
+ This error occurred while parsing the vcd file at \
+ {cursor:?}"
+ );
+ Err(msg)?;
+ }
+ };
+
+ // record timestamp at which this event occurs
+ lsb_indxs_of_string_tmstmp_vals_on_tmln
+ .push(LsbIdxOfTmstmpValOnTmln(curr_tmstmp_lsb_idx));
+ byte_len_of_string_tmstmp_vals_on_tmln.push(curr_tmstmp_len_u8);
+
+ // record value
+ string_vals.push(val);
+ Ok(())
+ }
+ SignalEnum::Alias { .. } => {
+ let (f, l) = (file!(), line!());
+ let msg = format!(
+ "Error near {f}:{l}, a signal alias should not point to a signal alias.\n\
+ This error occurred while parsing vcd file at {cursor:?}");
+ Err(msg)
+ }
+ }?;
+ }
+ // Store real values as a string as well and let the user parse it to an f64
+ "s" | " S" | "r" | "R" => {
+ let val = word[1..].to_string();
+ let (hash, cursor) = next_word!(word_reader)?;
+ // lokup signal idx
+ let signal_idx = signal_map.get(hash).ok_or(()).map_err(|_| {
+ format!(
+ "Error near {}:{}. Failed to lookup signal {hash} at {cursor:?}",
+ file!(),
+ line!()
+ )
+ })?;
+
+ let signal = vcd.dealiasing_signal_idx_to_signal_lookup_mut(signal_idx)?;
+
+ match signal {
+ SignalEnum::Data {
+ ref mut signal_error,
+ string_vals,
+ byte_len_of_string_tmstmp_vals_on_tmln,
+ lsb_indxs_of_string_tmstmp_vals_on_tmln,
+ ..
+ } => {
+ // if this is a bad signal, go ahead and skip it
+ if signal_error.is_some() {
+ continue;
+ }
+
+ // record timestamp at which this event occurs
+ lsb_indxs_of_string_tmstmp_vals_on_tmln
+ .push(LsbIdxOfTmstmpValOnTmln(curr_tmstmp_lsb_idx));
+ byte_len_of_string_tmstmp_vals_on_tmln.push(curr_tmstmp_len_u8);
+
+ // record string value
+ string_vals.push(val);
+ Ok(())
+ }
+ SignalEnum::Alias { .. } => {
+ let (f, l) = (file!(), line!());
+ let msg = format!(
+ "Error near {f}:{l}, a signal alias should not point to a signal alias.\n\
+ This error occurred while parsing vcd file at {cursor:?}");
+ Err(msg)
+ }
+ }?;
+ }
+ _ => {}
+ }
+ }
+
+ Ok(())
+}
diff --git a/src/vcd/parse/metadata.rs b/src/vcd/parse/metadata.rs
new file mode 100644
index 0000000..6e94a7c
--- /dev/null
+++ b/src/vcd/parse/metadata.rs
@@ -0,0 +1,335 @@
+// Copyright (C) 2022 Yehowshua Immanuel
+// This program is distributed under both the GPLV3 license
+// and the YEHOWSHUA license, both of which can be found at
+// the root of the folder containing the sources for this program.
+use chrono::prelude::{DateTime, Utc};
+use itertools::Itertools;
+
+use super::super::reader::{next_word, Cursor, WordReader};
+use super::super::types::{Metadata, Timescale, Version};
+
+use super::combinator_atoms::{digit, tag, take_until, take_while};
+use super::types::ParseResult;
+
+pub(super) fn parse_date(
+ word_and_ctx1: (&str, &Cursor),
+ word_and_ctx2: (&str, &Cursor),
+ word_and_ctx3: (&str, &Cursor),
+ word_and_ctx4: (&str, &Cursor),
+ word_and_ctx5: (&str, &Cursor),
+) -> Result, String> {
+ let day = {
+ // check for another word in the file
+ let (word, cursor) = word_and_ctx1;
+
+ let days = ["Mon", "Tue", "Wed", "Thu", "Fri", "Sat", "Sun"];
+ if !days.contains(&word) {
+ let msg = format!("Error near {}:{}.", file!(), line!());
+ let msg2 = format!("{word} is not a valid weekday : expected one of {days:?}\n");
+ let msg3 = format!("failure location: {cursor:?}");
+ return Err(format!("{}{}{}", msg, msg2, msg3));
+ }
+
+ word.to_string()
+ };
+
+ let month = {
+ // check for another word in the file
+ let (word, cursor) = word_and_ctx2;
+
+ let months = [
+ "Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sept", "Oct", "Nov", "Dec",
+ ];
+
+ if !months.contains(&word) {
+ let msg = format!("Error near {}:{}.", file!(), line!());
+ let msg2 = format!("{word} is not a valid month : expected one of {months:?}\n");
+ let msg3 = format!("failure location: {cursor:?}");
+ return Err(format!("{}{}{}", msg, msg2, msg3));
+ }
+
+ word.to_string()
+ };
+
+ let date = {
+ // check for another word in the file
+ let (word, cursor) = word_and_ctx3;
+
+ let date: u8 = match word.to_string().parse() {
+ Ok(date) => date,
+ Err(e) => return Err(format!("Error near {}:{}. {e}", file!(), line!())),
+ };
+
+ if date > 31 {
+ let msg = format!("Error near {}:{}.", file!(), line!());
+ let msg2 = format!("{word} is not a valid date : must be between 0 and 31\n");
+ let msg3 = format!("failure location: {cursor:?}");
+ return Err(format!("{}{}{}", msg, msg2, msg3));
+ }
+
+ date.to_string()
+ };
+
+ let (hh, mm, ss) = {
+ // get hour
+ let (word, cursor) = word_and_ctx4;
+
+ let res = take_until(word, b':');
+ res.assert_match()?;
+ let hh: u8 = res
+ .matched
+ .to_string()
+ .parse()
+ .map_err(|e| format!("Error near {}:{}. {e}", file!(), line!()))?;
+
+ if hh > 23 {
+ let msg = format!("Error near {}:{}.", file!(), line!());
+ let msg2 = format!("{hh} is not a valid hour : must be between 0 and 23\n");
+ let msg3 = format!("failure location: {cursor:?}");
+ return Err(format!("{}{}{}", msg, msg2, msg3));
+ }
+
+ // get minute
+ let word = &res.residual[1..]; // chop off colon which is at index 0
+ let res = take_until(word, b':');
+ res.assert_match()?;
+ let mm: u8 = res
+ .matched
+ .to_string()
+ .parse()
+ .map_err(|e| format!("Error near {}:{}. {e}", file!(), line!()))?;
+
+ if mm > 60 {
+ let msg = format!("Error near {}:{}.", file!(), line!());
+ let msg2 = format!("{mm} is not a valid minute : must be between 0 and 60\n");
+ let msg3 = format!("failure location: {cursor:?}");
+ return Err(format!("{}{}{}", msg, msg2, msg3));
+ }
+
+ // get second
+ // let ss : u8 = remainder.to_string().parse().unwrap();
+ res.assert_residual()?;
+ let residual = &res.residual[1..]; // chop of colon which is at index 0
+ let ss: u8 = residual
+ .to_string()
+ .parse()
+ .map_err(|e| format!("Error near {}:{}. {e}", file!(), line!()))?;
+
+ if ss > 60 {
+ let msg = format!("Error near {}:{}.", file!(), line!());
+ let msg2 = format!("{ss} is not a valid second : must be between 0 and 60\n");
+ let msg3 = format!("failure location: {cursor:?}");
+ return Err(format!("{}{}{}", msg, msg2, msg3));
+ }
+ (hh.to_string(), mm.to_string(), ss.to_string())
+ };
+
+ let year = {
+ // check for another word in the file
+ let (word, _) = word_and_ctx5;
+ word.to_string()
+ };
+
+ // unfortunately, the minutes, seconds, and hour could occur in an
+ // unexpected order
+ let full_date = format!("{day} {month} {date} {hh}:{mm}:{ss} {year}");
+ let full_date = DateTime::parse_from_str(full_date.as_str(), "%a %b %e %T %Y");
+ if full_date.is_ok() {
+ return Ok(full_date.unwrap().into());
+ }
+
+ Err(format!(
+ "Error near {}:{}. Failed to parse date.",
+ file!(),
+ line!()
+ ))
+}
+
+pub(super) fn parse_version(
+ word_reader: &mut WordReader,
+) -> Result {
+ let mut version = String::new();
+
+ loop {
+ let (word, _) = next_word!(word_reader)?;
+
+ if word == "$end" {
+ // truncate trailing whitespace
+ let version = version[0..(version.len() - 1)].to_string();
+ return Ok(Version(version));
+ } else {
+ version.push_str(word);
+ version.push(' ');
+ }
+ }
+}
+
+pub(super) fn parse_timescale(
+ word_reader: &mut WordReader,
+) -> Result<(Option, Timescale), String> {
+ // we might see `1ps $end` or `1 ps $end`
+ // first get timescale
+ let (word, _) = next_word!(word_reader)?;
+ let ParseResult { matched, residual } = take_while(word, digit);
+ let scalar = matched;
+
+ let scalar: u32 = scalar
+ .to_string()
+ .parse()
+ .map_err(|e| format!("Error near {}:{}. {e}", file!(), line!()))?;
+
+ let timescale = {
+ if residual.is_empty() {
+ let (word, _) = next_word!(word_reader)?;
+ let unit = match word {
+ "fs" => Ok(Timescale::Fs),
+ "ps" => Ok(Timescale::Ps),
+ "ns" => Ok(Timescale::Ns),
+ "us" => Ok(Timescale::Us),
+ "ms" => Ok(Timescale::Ms),
+ "s" => Ok(Timescale::S),
+ _ => Err(format!(
+ "Error near {}:{}. Unknown unit {word}.",
+ file!(),
+ line!()
+ )),
+ }?;
+
+ (Some(scalar), unit)
+ } else {
+ let unit = match residual {
+ "fs" => Ok(Timescale::Fs),
+ "ps" => Ok(Timescale::Ps),
+ "ns" => Ok(Timescale::Ns),
+ "us" => Ok(Timescale::Us),
+ "ms" => Ok(Timescale::Ms),
+ "s" => Ok(Timescale::S),
+ _ => Err(format!(
+ "Error near {}:{}. Unknown unit {residual}.",
+ file!(),
+ line!()
+ )),
+ }?;
+
+ (Some(scalar), unit)
+ }
+ };
+
+ // then check for the `$end` keyword
+ let (word, _) = next_word!(word_reader)?;
+ tag(word, "$end").assert_match()?;
+
+ Ok(timescale)
+}
+
+pub(super) fn parse_metadata(
+ word_reader: &mut WordReader,
+) -> Result {
+ let mut metadata = Metadata {
+ date: None,
+ version: None,
+ timescale: (None, Timescale::Unit),
+ };
+
+ loop {
+ // check for another word in the file
+ let (word, _) = next_word!(word_reader)?;
+
+ let ParseResult { matched, residual } = tag(word, "$");
+ match matched {
+ // we hope that this word stars with a `$`
+ "$" => {
+ match residual {
+ "date" => {
+ // a date is typically composed of the 5 following words which can
+ // occur in any order:
+ // {Day, Month, Date(number in month), hh:mm:ss, year}.
+ // Thus, we must lookahead read the 5 next words, and try our date
+ // parser on 5! = 120 permutations of the 5 words.
+ //
+ // It is also possible that within each permutation, the hours,
+ // minutes, and seconds could be in an unusual order, which means
+ // that we may search up to 6 different permutations oh hh::mm:ss,
+ // for an upper bound total of 720 permutations
+ //
+ // While looking ahead, if one of the 5 words in `$end`, we have to
+ // immediately stop trying to get more words.
+
+ let mut found_end = false;
+ let mut lookahead_5_words: Vec<(String, Cursor)> = Vec::new();
+
+ for _ in 0..5 {
+ let (word, cursor) = next_word!(word_reader)?;
+ let word = word.to_string();
+ match word.as_str() {
+ "$end" => {
+ found_end = true;
+ break;
+ }
+ _ => {
+ lookahead_5_words.push((word, cursor));
+ }
+ };
+ }
+
+ // we no longer attempt to parse date if we weren't able to lookahead 5
+ // words
+ if found_end {
+ continue;
+ }
+
+ let permutations = lookahead_5_words
+ .iter()
+ .permutations(lookahead_5_words.len());
+
+ // go ahead and search for a match amongst permuted date text
+ for mut permutations in permutations {
+ let (w1, s1) = permutations.pop().unwrap();
+ let arg_1 = (&w1[..], s1);
+
+ let (w2, s2) = permutations.pop().unwrap();
+ let arg_2 = (&w2[..], s2);
+
+ let (w3, s3) = permutations.pop().unwrap();
+ let arg_3 = (&w3[..], s3);
+
+ let (w4, s4) = permutations.pop().unwrap();
+ let arg_4 = (&w4[..], s4);
+
+ let (w5, s5) = permutations.pop().unwrap();
+ let arg_5 = (&w5[..], s5);
+
+ let parsed_date = parse_date(arg_1, arg_2, arg_3, arg_4, arg_5);
+
+ // store date and exit loop if a match is found
+ if parsed_date.is_ok() {
+ metadata.date = Some(parsed_date?);
+ break;
+ }
+ }
+ }
+ "version" => {
+ let version = parse_version(word_reader);
+ if version.is_ok() {
+ metadata.version = Some(version.unwrap());
+ }
+ }
+ "timescale" => {
+ let timescale = parse_timescale(word_reader);
+ if timescale.is_ok() {
+ metadata.timescale = timescale.unwrap();
+ }
+ }
+ "scope" => break,
+ "var" => break,
+ // we keep searching for words until we've found one of the following
+ // keywords, ["version", "timescale", "scope", "var"]
+ _ => {}
+ }
+ }
+ // if word does not start with `$`, then we keep looping
+ _ => {}
+ }
+ }
+ Ok(metadata)
+}
diff --git a/src/vcd/parse/scopes.rs b/src/vcd/parse/scopes.rs
new file mode 100644
index 0000000..5fe106b
--- /dev/null
+++ b/src/vcd/parse/scopes.rs
@@ -0,0 +1,522 @@
+// Copyright (C) 2022 Yehowshua Immanuel
+// This program is distributed under both the GPLV3 license
+// and the YEHOWSHUA license, both of which can be found at
+// the root of the folder containing the sources for this program.
+
+/// part of the vcd parser that handles parsing the signal tree and
+/// building the resulting signal tree
+use std::collections::HashMap;
+
+use super::super::reader::{curr_word, next_word, WordReader};
+use super::super::signal::{SignalEnum, SignalType};
+use super::super::types::{Scope, ScopeIdx, SignalIdx, VCD};
+
+use super::combinator_atoms::{ident, tag};
+use super::types::ParseResult;
+
+pub(super) fn parse_var(
+ word_reader: &mut WordReader,
+ parent_scope_idx: ScopeIdx,
+ vcd: &mut VCD,
+ signal_map: &mut HashMap,
+ path: &Vec,
+) -> Result<(), String> {
+ let (word, cursor) = next_word!(word_reader)?;
+ let expected_types = [
+ "event",
+ "integer",
+ "parameter",
+ "real",
+ "realtime",
+ "reg",
+ "string",
+ "supply0",
+ "supply1",
+ "time",
+ "tri",
+ "triand",
+ "trior",
+ "trireg",
+ "tri0",
+ "tri1",
+ "wand",
+ "wire",
+ "wor",
+ ];
+
+ // $var parameter 3 a IDLE $end
+ // ^^^^^^^^^ - var_type
+ let var_type = match word {
+ "event" => Ok(SignalType::Event),
+ "integer" => Ok(SignalType::Integer),
+ "parameter" => Ok(SignalType::Parameter),
+ "real" => Ok(SignalType::Real),
+ "realtime" => Ok(SignalType::RealTime),
+ "reg" => Ok(SignalType::Reg),
+ "string" => Ok(SignalType::Str),
+ "supply0" => Ok(SignalType::Supply0),
+ "supply1" => Ok(SignalType::Supply1),
+ "tri" => Ok(SignalType::Tri),
+ "triand" => Ok(SignalType::TriAnd),
+ "trior" => Ok(SignalType::TriOr),
+ "trireg" => Ok(SignalType::TriReg),
+ "tri0" => Ok(SignalType::Tri0),
+ "tri1" => Ok(SignalType::Tri1),
+ "time" => Ok(SignalType::Time),
+ "wand" => Ok(SignalType::WAnd),
+ "wire" => Ok(SignalType::Wire),
+ "wor" => Ok(SignalType::WOr),
+ _ => {
+ let err = format!(
+ "Error near {}:{} \
+ found keyword `{word}` but expected one of \
+ {expected_types:?} on {cursor:?}",
+ file!(),
+ line!()
+ );
+ Err(err)
+ }
+ }?;
+
+ let (word, cursor) = next_word!(word_reader)?;
+
+ let parse_err = format!("failed to parse as usize on {cursor:?}");
+
+ // $var parameter 3 a IDLE $end
+ // ^ - num_bits
+ let num_bits = match var_type {
+ SignalType::Event
+ | SignalType::Integer
+ | SignalType::Parameter
+ | SignalType::Reg
+ | SignalType::Supply0
+ | SignalType::Supply1
+ | SignalType::Tri
+ | SignalType::TriAnd
+ | SignalType::TriOr
+ | SignalType::TriReg
+ | SignalType::Tri0
+ | SignalType::Tri1
+ | SignalType::Time
+ | SignalType::WAnd
+ | SignalType::Wire
+ | SignalType::WOr => {
+ let num_bits = word
+ .parse::()
+ .unwrap_or_else(|_| panic!("{}", parse_err));
+ let num_bits = u32::try_from(num_bits).map_err(|_| {
+ format!(
+ "Error near {}:{} while parsing vcd file at {cursor:?}. \
+ This signal has {num_bits} > 2^32 - 1 bits.",
+ file!(),
+ line!()
+ )
+ })?;
+ Some(num_bits)
+ }
+ // for strings, reals, and realtimes we don't really care what the number of bits is
+ _ => None,
+ };
+
+ // $var parameter 3 a IDLE $end
+ // ^ - signal_alias
+ let (word, _) = next_word!(word_reader)?;
+ let signal_alias = word.to_string();
+
+ // $var parameter 3 a IDLE $end
+ // ^^^^ - full_signal_name(can extend until $end)
+ let mut full_signal_name = Vec::::new();
+ let mut size = None;
+ loop {
+ let (word, _) = next_word!(word_reader)?;
+ match word {
+ "$end" => break,
+ other if other.starts_with('[') => size = Some(other.to_string()),
+ _ => full_signal_name.push(word.to_string()),
+ }
+ }
+ let full_signal_name = full_signal_name.join(" ");
+
+ let num_bytes = if num_bits.is_some() {
+ let bytes_required = SignalEnum::bytes_required(num_bits.unwrap(), &full_signal_name)?;
+ Some(bytes_required)
+ } else {
+ None
+ };
+
+ // Is the current variable an alias to a signal already encountered?
+ // if so, handle ref_signal_idx accordingly, if not, add signal to hash
+ // map
+ let (signal, signal_idx) = match signal_map.get(&signal_alias) {
+ Some(ref_signal_idx) => {
+ let signal_idx = SignalIdx(vcd.all_signals.len());
+ let signal = SignalEnum::Alias {
+ name: full_signal_name.clone(),
+ path: path
+ .iter()
+ .cloned()
+ .chain([full_signal_name])
+ .collect::>(),
+ signal_alias: *ref_signal_idx,
+ };
+ (signal, signal_idx)
+ }
+ None => {
+ let signal_idx = SignalIdx(vcd.all_signals.len());
+ signal_map.insert(signal_alias.to_string(), signal_idx);
+ let signal = SignalEnum::Data {
+ name: full_signal_name.clone(),
+ path: path
+ .iter()
+ .cloned()
+ .chain([full_signal_name])
+ .collect::>(),
+ signal_type: var_type,
+ index: size,
+ signal_error: None,
+ num_bits,
+ num_bytes,
+ self_idx: signal_idx,
+ nums_encoded_as_fixed_width_le_u8: vec![],
+ string_vals: vec![],
+ lsb_indxs_of_num_tmstmp_vals_on_tmln: vec![],
+ byte_len_of_num_tmstmp_vals_on_tmln: vec![],
+ byte_len_of_string_tmstmp_vals_on_tmln: vec![],
+ lsb_indxs_of_string_tmstmp_vals_on_tmln: vec![],
+ };
+ (signal, signal_idx)
+ }
+ };
+
+ vcd.all_signals.push(signal);
+ let ScopeIdx(parent_scope_idx_usize) = parent_scope_idx;
+ let parent_scope = vcd.all_scopes.get_mut(parent_scope_idx_usize).unwrap();
+ parent_scope.child_signals.push(signal_idx);
+
+ Ok(())
+}
+
+/// Sometimes, variables can be listed outside of scopes.
+/// We call these orphaned vars.
+fn parse_orphaned_vars(
+ word_reader: &mut WordReader,
+ vcd: &mut VCD,
+ signal_map: &mut HashMap,
+) -> Result<(), String> {
+ // create scope for unscoped signals if such a scope does not
+ // yet exist
+ let scope_name = "Orphaned Signals";
+
+ // set default scope_idx to the count of existing scope as we
+ // generally set scope.self_idx to the number of existing scopes
+ // when that particular scope was inserted
+ let mut scope_idx = ScopeIdx(vcd.all_scopes.len());
+
+ // Override scope_idx if we find a scope named "Orphaned Signals"
+ // already exists
+ let mut scope_already_exists = false;
+ for scope in &vcd.all_scopes {
+ if scope.name == scope_name {
+ scope_idx = scope.self_idx;
+ scope_already_exists = true;
+ break;
+ }
+ }
+
+ if !scope_already_exists {
+ vcd.all_scopes.push(Scope {
+ name: scope_name.to_string(),
+ self_idx: scope_idx,
+ child_signals: vec![],
+ child_scopes: vec![],
+ });
+ vcd.root_scopes.push(scope_idx);
+ }
+
+ // we can go ahead and parse the current var as we've already encountered
+ // "$var" before now.
+ parse_var(word_reader, scope_idx, vcd, signal_map, &vec![])?;
+
+ loop {
+ let (word, cursor) = next_word!(word_reader)?;
+
+ match word {
+ "$var" => {
+ parse_var(word_reader, scope_idx, vcd, signal_map, &vec![])?;
+ }
+ "$scope" => break,
+ _ => {
+ let msg = format!(
+ "Error near {}:{}.\
+ Expected $scope or $var, found \
+ {word} at {cursor:?}",
+ file!(),
+ line!()
+ );
+ Err(msg)?;
+ }
+ };
+ }
+
+ Ok(())
+}
+
+fn parse_scopes_inner(
+ word_reader: &mut WordReader,
+ parent_scope_idx: Option,
+ vcd: &mut VCD,
+ signal_map: &mut HashMap,
+ path: &Vec,
+) -> Result<(), String> {
+ // $scope module reg_mag_i $end
+ // ^^^^^^ - module keyword
+ let (keyword, cursor) = next_word!(word_reader)?;
+
+ let expected = ["module", "begin", "task", "function", "fork"];
+ if expected.contains(&keyword) {
+ Ok(())
+ } else {
+ let err = format!(
+ "Error near {}:{}. \
+ found keyword `{keyword}` but expected one of \
+ {expected:?} on {cursor:?}",
+ file!(),
+ line!()
+ );
+ Err(err)
+ }?;
+
+ // $scope module reg_mag_i $end
+ // ^^^^^^^^^ - scope name
+ let (scope_name, _) = next_word!(word_reader)?;
+ // In some cases there are VCD files which have scopes without names.
+ // since these occur in the wild, we'll tolerate them even if it is unclear
+ // if it is supported or not by the spec.
+ if scope_name != "$end" {
+ let mut path = path.clone();
+ path.push(scope_name.to_string());
+
+ let curr_scope_idx = ScopeIdx(vcd.all_scopes.len());
+
+ // register this scope as a child of the current parent scope
+ // if there is a parent scope, or else we register this scope as
+ // root scope
+ match parent_scope_idx {
+ Some(ScopeIdx(parent_scope_idx)) => {
+ let parent_scope = vcd.all_scopes.get_mut(parent_scope_idx).unwrap();
+ parent_scope.child_scopes.push(curr_scope_idx);
+ }
+ None => vcd.root_scopes.push(curr_scope_idx),
+ }
+
+ // add this scope to list of existing scopes
+ vcd.all_scopes.push(Scope {
+ name: scope_name.to_string(),
+ self_idx: curr_scope_idx,
+ child_signals: vec![],
+ child_scopes: vec![],
+ });
+
+ // $scope module reg_mag_i $end
+ // ^^^^ - end keyword
+ ident(word_reader, "$end")?;
+
+ loop {
+ let (word, cursor) = next_word!(word_reader)?;
+ let ParseResult { matched, residual } = tag(word, "$");
+ match matched {
+ // we hope that this word starts with a `$`
+ "$" => {
+ match residual {
+ "scope" => {
+ // recursive - parse inside of current scope tree
+ parse_scopes_inner(
+ word_reader,
+ Some(curr_scope_idx),
+ vcd,
+ signal_map,
+ &path,
+ )?;
+ }
+ "var" => {
+ parse_var(word_reader, curr_scope_idx, vcd, signal_map, &path)?;
+ }
+ "upscope" => {
+ ident(word_reader, "$end")?;
+ break;
+ }
+ // we ignore comments
+ "comment" => loop {
+ if ident(word_reader, "$end").is_ok() {
+ break;
+ }
+ },
+ _ => {
+ let err = format!(
+ "Error near {}:{}. \
+ found keyword `{residual}` but expected \
+ `$scope`, `$var`, `$comment`, or `$upscope` \
+ on {cursor:?}",
+ file!(),
+ line!()
+ );
+ return Err(err);
+ }
+ }
+ }
+ _ => {
+ let err = format!(
+ "Error near {}:{}. \
+ found keyword `{matched}` but \
+ expected `$` on {cursor:?}",
+ file!(),
+ line!()
+ );
+ return Err(err);
+ }
+ }
+ }
+ } else {
+ // We'll be conservative and only allow new scopes in this case, and make the nameless
+ // scope completely transparent. I.e.
+ // $scope module a $end
+ // $scope module $end
+ // $scope module b $end
+ // ...
+ // $upscope
+ // $upscope
+ // $upscope
+ // will create `a.b`
+ loop {
+ let (word, cursor) = next_word!(word_reader)?;
+ let ParseResult { matched, residual } = tag(word, "$");
+ match matched {
+ // we hope that this word starts with a `$`
+ "$" => {
+ match residual {
+ "scope" => {
+ // recursive - parse inside of current scope tree
+ parse_scopes_inner(
+ word_reader,
+ parent_scope_idx,
+ vcd,
+ signal_map,
+ &path,
+ )?;
+ }
+ "upscope" => {
+ ident(word_reader, "$end")?;
+ break;
+ }
+ // we ignore comments
+ "comment" => loop {
+ if ident(word_reader, "$end").is_ok() {
+ break;
+ }
+ },
+ _ => {
+ let err = format!(
+ "Error near {}:{}. \
+ found keyword `{residual}` in annonyoums scope but expected \
+ `$scope`, `$comment`, or `$upscope` \
+ on {cursor:?}",
+ file!(),
+ line!()
+ );
+ return Err(err);
+ }
+ }
+ }
+ _ => {
+ let err = format!(
+ "Error near {}:{}. \
+ found keyword `{matched}` but \
+ expected `$` on {cursor:?}",
+ file!(),
+ line!()
+ );
+ return Err(err);
+ }
+ }
+ }
+ }
+
+ Ok(())
+}
+
+pub(super) fn parse_scopes(
+ word_reader: &mut WordReader,
+ vcd: &mut VCD,
+ signal_map: &mut HashMap,
+) -> Result<(), String> {
+ // get the current word
+ let (word, _) = curr_word!(word_reader)?;
+
+ // we may have orphaned vars that occur before the first scope
+ if word == "$var" {
+ parse_orphaned_vars(word_reader, vcd, signal_map)?;
+ }
+
+ // get the current word
+ let (word, cursor) = curr_word!(word_reader)?;
+
+ // the current word should be "scope", as `parse_orphaned_vars`(if it
+ // was called), should have terminated upon encountering "$scope".
+ // If `parse_orphaned_vars` was not called, `parse_scopes` should still
+ // have only been called if the caller encountered the word "$scope"
+ if word != "$scope" {
+ let msg = format!(
+ "Error near {}:{}.\
+ Expected $scope or $var, found \
+ {word} at {cursor:?}",
+ file!(),
+ line!()
+ );
+ return Err(msg);
+ }
+
+ // now for the interesting part
+ parse_scopes_inner(word_reader, None, vcd, signal_map, &vec![])?;
+
+ // let err = format!("reached end of file without parser leaving {}", function_name!());
+ let expected_keywords = ["$scope", "$enddefinitions"];
+
+ // there could be multiple signal trees, and unfortunately, we
+ // can't merge the earlier call to `parse_scopes_inner` into this loop
+ // because this loop gets a word from `next_word` instead of
+ // `curr_word()`.
+ loop {
+ let (word, cursor) = next_word!(word_reader)?;
+
+ match word {
+ "$scope" => {
+ parse_scopes_inner(word_reader, None, vcd, signal_map, &vec![])?;
+ }
+ "$enddefinitions" => {
+ ident(word_reader, "$end")?;
+ break;
+ }
+ "$comment" => {
+ // although we don't store comments, we still need to advance the
+ // word_reader cursor to the end of the comment
+ loop {
+ if ident(word_reader, "$end").is_ok() {
+ break;
+ }
+ }
+ }
+ _ => {
+ let err = format!(
+ "Error near {}:{} \
+ found keyword `{word}` but expected one of \
+ {expected_keywords:?} on {cursor:?}",
+ file!(),
+ line!()
+ );
+ return Err(err);
+ }
+ }
+ }
+
+ Ok(())
+}
diff --git a/src/vcd/parse/types.rs b/src/vcd/parse/types.rs
new file mode 100644
index 0000000..25644ff
--- /dev/null
+++ b/src/vcd/parse/types.rs
@@ -0,0 +1,27 @@
+// Copyright (C) 2022 Yehowshua Immanuel
+// This program is distributed under both the GPLV3 license
+// and the YEHOWSHUA license, both of which can be found at
+// the root of the folder containing the sources for this program.
+#[derive(Debug)]
+pub(super) struct ParseResult<'a> {
+ pub(super) matched: &'a str,
+ pub(super) residual: &'a str,
+}
+
+impl<'a> ParseResult<'a> {
+ pub(super) fn assert_match(&self) -> Result<&str, String> {
+ if self.matched.is_empty() {
+ Err("no match".to_string())
+ } else {
+ Ok(self.matched)
+ }
+ }
+
+ pub(super) fn assert_residual(&self) -> Result<&str, String> {
+ if self.residual.is_empty() {
+ Err("no residual".to_string())
+ } else {
+ Ok(self.residual)
+ }
+ }
+}
diff --git a/src/vcd/reader.rs b/src/vcd/reader.rs
new file mode 100644
index 0000000..6ef242f
--- /dev/null
+++ b/src/vcd/reader.rs
@@ -0,0 +1,131 @@
+// Copyright (C) 2022 Yehowshua Immanuel
+// This program is distributed under both the GPLV3 license
+// and the YEHOWSHUA license, both of which can be found at
+// the root of the folder containing the sources for this program.
+use std::collections::VecDeque;
+use std::io;
+use std::io::BufRead;
+use std::slice;
+use std::str;
+
+#[derive(Debug, Clone)]
+pub(super) struct Line(pub(super) usize);
+#[derive(Debug, Clone)]
+pub(super) struct Word(pub(super) usize);
+#[derive(Debug, Clone)]
+pub(super) struct Cursor(pub(super) Line, pub(super) Word);
+
+pub(super) struct WordReader {
+ reader: io::BufReader,
+ eof: bool,
+ buffers: Vec,
+ curr_line: usize,
+ str_slices: VecDeque<(*const u8, usize, Cursor)>,
+ curr_slice: Option<(*const u8, usize, Cursor)>,
+}
+
+impl WordReader {
+ pub(super) fn new(file: R) -> WordReader {
+ let reader = io::BufReader::new(file);
+ WordReader {
+ reader,
+ eof: false,
+ buffers: vec![],
+ curr_line: 0,
+ str_slices: VecDeque::new(),
+ curr_slice: None,
+ }
+ }
+
+ pub(super) fn next_word(&mut self) -> Option<(&str, Cursor)> {
+ // although reaching the eof is not technically an error, in most cases,
+ // we treat it like one in the rest of the codebase.
+
+ // if there are no more words in the buffer, attempt to read more content
+ // from the file
+ if self.str_slices.is_empty() {
+ self.buffers.clear();
+
+ if self.eof {
+ return None;
+ }
+
+ let num_buffers = 10;
+
+ for buf_idx in 0..num_buffers {
+ self.buffers.push(String::new());
+ self.curr_line += 1;
+ let bytes_read = self.reader.read_line(&mut self.buffers[buf_idx]).unwrap();
+
+ // if we've reached the end of the file on the first attempt to read
+ // a line in this for loop, no further attempts are necessary and we
+ if bytes_read == 0 {
+ self.eof = true;
+ break;
+ }
+
+ let words = self.buffers[buf_idx].split_ascii_whitespace();
+
+ for word in words.enumerate() {
+ let (word_idx, word) = word;
+ let position = Cursor(Line(self.curr_line), Word(word_idx + 1));
+ self.str_slices
+ .push_back((word.as_ptr(), word.len(), position))
+ }
+ }
+ }
+
+ // if after we've attempted to read in more content from the file,
+ // there are still no words...
+ if self.str_slices.is_empty() {
+ return None;
+ }
+
+ // if we make it here, we return the next word
+ unsafe {
+ let (ptr, len, position) = self.str_slices.pop_front().unwrap();
+ let slice = slice::from_raw_parts(ptr, len);
+ self.curr_slice = Some((ptr, len, position.clone()));
+ return Some((str::from_utf8(slice).unwrap(), position));
+ };
+ }
+
+ pub(super) fn curr_word(&mut self) -> Option<(&str, Cursor)> {
+ match &self.curr_slice {
+ Some(slice) => unsafe {
+ let (ptr, len, position) = slice.clone();
+ let slice = slice::from_raw_parts(ptr, len);
+ return Some((str::from_utf8(slice).unwrap(), position));
+ },
+ None => None,
+ }
+ }
+}
+
+macro_rules! next_word {
+ ($word_reader:ident) => {
+ $word_reader.next_word().ok_or(()).map_err(|_| {
+ format!(
+ "Error near {}:{}. Did not expect to reach end of file here.",
+ file!(),
+ line!()
+ )
+ })
+ };
+}
+
+macro_rules! curr_word {
+ ($word_reader:ident) => {
+ $word_reader.curr_word().ok_or(()).map_err(|_| {
+ format!(
+ "Error near {}:{}. A call to curr_word! shouldn't \
+ fail unless next_word has not yet been invoked.",
+ file!(),
+ line!()
+ )
+ })
+ };
+}
+
+pub(super) use curr_word;
+pub(super) use next_word;
diff --git a/src/vcd/signal.rs b/src/vcd/signal.rs
new file mode 100644
index 0000000..b87e1a2
--- /dev/null
+++ b/src/vcd/signal.rs
@@ -0,0 +1,715 @@
+// Copyright (C) 2022 Yehowshua Immanuel
+// This program is distributed under both the GPLV3 license
+// and the YEHOWSHUA license, both of which can be found at
+// the root of the folder containing the sources for this program.
+use super::types;
+use super::types::SignalIdx;
+use num::BigUint;
+
+// Index to the least significant byte of a timestamp
+// value on the timeline
+#[derive(Debug, Copy, Clone)]
+pub struct LsbIdxOfTmstmpValOnTmln(pub(super) u32);
+
+#[derive(Debug, Eq, PartialEq, Clone)]
+pub enum SignalType {
+ Event,
+ Integer,
+ Parameter,
+ Real,
+ RealTime,
+ Reg,
+ Str,
+ Supply0,
+ Supply1,
+ Time,
+ Tri,
+ TriAnd,
+ TriOr,
+ TriReg,
+ Tri0,
+ Tri1,
+ WAnd,
+ Wire,
+ WOr,
+}
+
+#[derive(Debug, PartialEq)]
+pub enum SignalValue {
+ BigUint(BigUint),
+ String(String),
+}
+
+pub struct QueryResult {
+ pub current: Option<(TimeStamp, T)>,
+ pub next: Option,
+}
+
+pub struct Signal<'a>(pub(super) &'a SignalEnum);
+
+impl<'a> Signal<'a> {
+ pub fn name(&self) -> String {
+ let Signal(signal_enum) = &self;
+ signal_enum.name()
+ }
+
+ pub fn name_with_index(&self) -> String {
+ let Signal(signal_enum) = &self;
+ signal_enum.name_with_index()
+ }
+
+ pub fn index(&self) -> Option {
+ let Signal(signal_enum) = &self;
+ signal_enum.index()
+ }
+
+ pub fn path(&self) -> &[String] {
+ match self.0 {
+ SignalEnum::Data { path, .. } => path,
+ SignalEnum::Alias { path, .. } => path,
+ }
+ }
+
+ pub fn signal_type(&self) -> Option<&SignalType> {
+ let Signal(signal_enum) = &self;
+ signal_enum.signal_type()
+ }
+
+ pub fn real_idx(&self) -> SignalIdx {
+ match self.0 {
+ SignalEnum::Data { self_idx, .. } => *self_idx,
+ SignalEnum::Alias { signal_alias, .. } => *signal_alias,
+ }
+ }
+
+ pub fn num_bits(&self) -> Option {
+ let Signal(signal_enum) = &self;
+ signal_enum.bits_required()
+ }
+
+ // NOTE: (zoq) I am removing thse because they aren't used in Surfer so I can't test them
+ // properly
+ /*
+ pub fn query_string_val_on_tmln(
+ &self,
+ desired_time: &BigUint,
+ vcd: &types::VCD,
+ ) -> Result {
+ let Signal(signal_enum) = &self;
+ signal_enum
+ .query_string_val_on_tmln(desired_time, &vcd.tmstmps_encoded_as_u8s, &vcd.all_signals)
+ .map(|QueryResult{current, next: _}| current.map(|c| c.1))
+ }
+
+ pub fn query_num_val_on_tmln(
+ &self,
+ desired_time: &BigUint,
+ vcd: &types::VCD,
+ ) -> Result